dataX实例,mysqL输入转换为HDFs

DROP TABLE accesslog;
CREATE TABLE accesslog(
srcip VARCHAR(20),
destip VARCHAR(20),
protocol SMALLINT,
access_time VARCHAR(20)
);
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 1, '20211213000001');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 1, '20211213000002');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 0, '20211213000003');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 1, '20211213000004');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 0, '20211213000005');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 1, '20211213000006');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 0, '20211213000007');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 1, '20211213000008');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 0, '20211213000009');
INSERT INTO accesslog VALUES ('192.168.0.1', '127.0.0.1', 1, '20211213000010');