alibaba-flink-connectors-flink-1.5.2-compatible.zip
需积分: 14 137 浏览量
2021-12-10
14:42:26
上传
评论
收藏 166KB ZIP 举报
alibaba-flink-connectors-flink-1.5.2-compatible.zip （80个子文件） 
alibaba-flink-connectors-flink-1.5.2-compatible sls-shaded-sdk 
pom.xml 4KB datahub-connector src main java com alibaba flink connectors datahub datastream source DatahubSourceFunction.java 9KB DatahubRecordReader.java 10KB DatahubShardInputSplit.java 2KB sink DatahubRecordResolver.java 1KB DatahubSinkFunction.java 2KB DatahubOutputFormat.java 14KB example DatahubSinkFunctionExample.java 3KB DatahubSourceFunctionExample.java 3KB util DatahubClientProvider.java 3KB pom.xml 7KB LICENSE 11KB tools maven suppressions.xml 2KB suppressions-optimizer.xml 11KB checkstyle.xml 22KB spotbugs-exclude.xml 10KB suppressions-core.xml 12KB scalastyle-config.xml 7KB suppressions-runtime.xml 23KB README.md 41B sls-connector src test java com alibaba flink connectors sls datastream sink SlsOutputFormatTest.java 4KB LogProducerProviderTest.java 2KB main java com alibaba flink connectors sls datastream source SlsSourceFunction.java 9KB SlsInputSplit.java 1KB SlsClientProvider.java 3KB SlsRecordReader.java 14KB sink DefaultSlsSinkFunction.java 1KB SlsRecordResolver.java 1KB LogProducerProvider.java 4KB SlsSinkFunction.java 2KB DefaultSlsRecordResolver.java 1KB SlsOutputFormat.java 11KB SlsRecord.java 2KB pom.xml 2KB pom.xml 2KB NOTICE 583B cloudhbase-connector src test java com alibaba flink connectors cloudhbase sink CloudHBaseSinkFunctionTest.java 3KB main java com alibaba flink connectors cloudhbase sink CloudHBaseSinkFunction.java 10KB CloudHBaseRecordResolver.java 1KB example CloudHBaseSinkFunctionExample.java 5KB pom.xml 3KB aliyun-connectors-common src main java com alibaba flink connectors common conf BlinkOptions.java 3KB converter RecordConverter.java 1KB source AbstractParallelSource.java 4KB SourceUtils.java 7KB AbstractParallelSourceBase.java 12KB WatermarkProvider.java 204B AbstractLocatableParallelSource.java 2KB AbstractDynamicParallelSource.java 7KB metrics SumAndCount.java 3KB sink OutputFormatSinkFunction.java 4KB TupleOutputFormatSinkFunction.java 4KB Syncable.java 1KB HasRetryTimeout.java 982B TupleRichOutputFormat.java 2KB resolver RecordResolver.java 1KB exception NotEnoughParamsException.java 1KB ErrorUtils.java 1KB ConnectorException.java 2KB util BlinkStringUtil.java 3KB RetryUtils.java 5KB ConnectionPool.java 2KB DateUtil.java 3KB errorcode ErrorFactory.java 11KB ConnectorErrorCode.java 25KB ConnectorErrors.java 1KB reader Interruptible.java 1002B AbstractPartitionNumsListener.java 3KB RecordReader.java 2KB ParallelReader.java 22KB SequenceReader.java 3KB Constants.java 225B sts StsParamValidateUtil.java 2KB StsServiceRequest.java 3KB StsConstants.java 1KB DecodeUtil.java 2KB AbstractClientProvider.java 8KB MetricUtils.java 5KB pom.xml 2KB .gitignore 199B资源评论
