throws IOException; /** * Indicate the Source type. */ Boundedness getSourceBoundedness(); /** * Create Source Reader. */ SourceReader createReader(SourceReader.Context reader... getSplitCoordinatorCheckpointSerializer() { return new SimpleBinarySerializer<>(); } /** * Create type info converter for the source, default value {@link BitSailTypeInfoConverter} */...
throws IOException; /** * Indicate the Source type. */ Boundedness getSourceBoundedness(); /** ... default value {@link BitSailTypeInfoConverter} */ default TypeInfoConverter createTypeInfoConverter() { return new BitSailTypeInfoConverter(); ...
(SOURCE_READER_INSTANCE_NAME_TEMPLATE, cluster, topic, consumerGroup, UUID.randomUUID())); consumer.setConsumerPullTimeoutMillis(pollTimeout); consumer.start(); } catch (Exception ... [] typeInfos; private String[] fieldNames; private transient DeserializationSchema deserializationSchema; public TextInputFormatDeserializationSchema(BitSailConfiguration deserializationCon...
同时创建自己的工作分支,使用该分支开发自己的Connector。项目地址:[https://github.com/bytedance/bitsail.git。](https://github.com/bytedance/bitsail.git%E3%80%82)项目结构如下:![image.png](https://... [] typeInfos; private final transient int totalCount; private final transient RateLimiter fakeGenerateRate; private final transient AtomicLong counter; private final FakeRowGenerator fakeR...