没有合适的资源?快使用搜索试试~ 我知道了~
bahir-flink:Apache Bahir Flink的镜像
共248个文件
java:179个
xml:17个
scala:16个
需积分: 12 0 下载量 175 浏览量
2021-04-28
21:44:37
上传
评论
收藏 1.08MB ZIP 举报
温馨提示
阿帕奇·巴希尔(Flink) Apache Bahir提供了对分布式分析平台(例如Apache Spark:trade_mark:和ApacheFlink:registered:)的扩展。 该存储库用于Apache Flink扩展。 贡献Flink连接器 Bahir社区非常欢迎Apache Flink的新连接器贡献。 我们要求贡献者首先打开描述计划中的更改。 请确保将“ Flink Streaming Connector”放在“组件”字段中。 一旦社区同意计划的更改是合适的,您可以在“ bahir-flink”存储库中打开拉取请求。 请遵循与现有代码相同的目录结构。 社区将审查您的更改,并提出改进代码的建议,直到我们可以将其合并到主存储库中为止。 建筑物巴希尔 Bahir使用 :trade_mark:构建。 要构建Bahir及其示例程序,请运行: mvn -DskipTests clean install 运行测试 测试首先需要 。 一旦构建
资源推荐
资源详情
资源评论
收起资源包目录
bahir-flink:Apache Bahir Flink的镜像 (248个子文件)
sink.conf 1KB
source.conf 1KB
feeder_actor.conf 1KB
.gitattributes 337B
.gitignore 212B
PinotSinkGlobalCommitter.java 22KB
PinotSinkTest.java 20KB
SiddhiCEPITCase.java 19KB
PinotSink.java 18KB
KuduCatalogTest.java 15KB
AbstractSiddhiOperator.java 15KB
KuduTableUtils.java 14KB
RedisSinkITCase.java 13KB
KuduCatalog.java 13KB
RedisContainer.java 13KB
SiddhiStream.java 12KB
FlinkJedisSentinelConfig.java 11KB
KuduTestBase.java 10KB
AMQSourceTest.java 10KB
RedisSink.java 10KB
ActiveMQConnectorITCase.java 10KB
AMQSource.java 10KB
FlinkJedisClusterConfig.java 9KB
SiddhiCEP.java 9KB
KuduTableFactory.java 9KB
RedisClusterContainer.java 9KB
PinotTestBase.java 9KB
FlinkJedisPoolConfig.java 9KB
KuduTableFactoryTest.java 9KB
InfluxDBConfig.java 9KB
PinotSinkWriter.java 8KB
AkkaSourceTest.java 8KB
SiddhiOperatorContext.java 8KB
KuduTableSourceTest.java 8KB
KuduTableSource.java 7KB
KuduSinkTest.java 7KB
RedisCommandDescription.java 7KB
AbstractReadOnlyCatalog.java 7KB
KuduWriterConfig.java 7KB
PinotTestHelper.java 7KB
StreamSchema.java 6KB
RedisHandlerServices.java 6KB
KuduReader.java 6KB
RedisCommandsContainerBuilder.java 6KB
PinotWriterSegment.java 6KB
AMQSink.java 6KB
AMQSinkTest.java 6KB
RedisCommandsContainer.java 6KB
KuduFilterInfo.java 6KB
SiddhiTypeFactory.java 6KB
PinotControllerClient.java 6KB
KuduWriter.java 6KB
KuduRowInputFormat.java 5KB
RedisSinkTest.java 5KB
SiddhiTupleFactory.java 5KB
FlumeSink.java 5KB
KuduSink.java 5KB
KuduTypeUtils.java 5KB
FlinkJedisConfigBase.java 5KB
StreamSchemaTest.java 5KB
RedisDescriptorTest.java 5KB
RedisSinkPublishITCase.java 5KB
AkkaSource.java 5KB
KuduOutputFormatTest.java 4KB
KuduTableInfo.java 4KB
AMQSourceConfig.java 4KB
RedisSinkZIncrByTest.java 4KB
PinotControllerHttpClient.java 4KB
RandomWordSource.java 4KB
StreamOutputHandler.java 4KB
StreamInMemOutputHandler.java 4KB
AMQSinkConfig.java 4KB
RedisTableSink.java 4KB
InfluxDBSink.java 4KB
InfluxDBSinkExample.java 4KB
RedisHandlerTest.java 4KB
SiddhiStreamOperator.java 4KB
KuduOutputFormat.java 4KB
CustomPlusFunctionExtension.java 4KB
AbstractSingleOperationMapper.java 4KB
KuduTableSink.java 4KB
RedisCommand.java 4KB
RedisSentinelClusterTest.java 4KB
KuduInputFormatTest.java 3KB
RedisCommandsContainerBuilderTest.java 3KB
Redis.java 3KB
RowRedisMapper.java 3KB
PojoOperationMapperTest.java 3KB
SiddhiStreamSchema.java 3KB
ReceiverActor.java 3KB
PinotSinkGlobalCommittableSerializer.java 3KB
JedisClusterConfigTest.java 3KB
AMQExceptionListenerTest.java 3KB
FlinkJedisSentinelConfigHandler.java 3KB
FlumeUtils.java 3KB
FlinkJedisClusterConfigHandler.java 3KB
PinotSinkWriterStateSerializer.java 3KB
Event.java 3KB
TupleOpertaionMapperTest.java 3KB
FeederActor.java 3KB
共 248 条
- 1
- 2
- 3
资源评论
Mika.w
- 粉丝: 32
- 资源: 4592
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- 基于Pytorch复现Point-Transformer,用于ShapeNet数据集点云分割
- 【医学影像分析】2D超声图像的分割检测(Ultrasound Nerve Segmentation - Kaggle数据集)
- 嘎嘎香的五款神仙谷歌插件
- .arch书源导入教程.mp4
- 贪心算法介绍及代码示例讲解
- CR13SP35MSI64 Crystal 水晶报表运行组件最后版本64位
- 图像分类数据集:玉米叶是否感染分类数据集(2分类,包含训练集、验证集)
- 小U商城.zip
- 高光谱图像计算机视觉分类图像预处理工具集,包含去除图片无关背景,数据增强,生成标签文件等功能
- (顶刊复现)基于配电网韧性提升的应急移动电源预配置和动态调度(下)-MPS动态调度
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功