没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
mvn clean mvn install将代码打成jar包后,上传到flume安装目录下的lib文件夹中,同时需要上传SQL的驱动jar包 -------------测试假脱机目录源-------------------------- conf:dbsql_sink.conf Name the components on this agent a1.sources = r1 a1.sinks = k1 a1.channels = c1 Describe/configure the source #a1.sources.r1.type = spooldir #a1.sources.r1.spoolDir = /home/rui/log/flumespool #a1.sources.r1.fileHeader = true a1.sources.r1.type = exec a1.sourc
资源推荐
资源详情
资源评论
收起资源包目录
flume_sink_ext:flume收集日志到postgrepsql ,es扩展 (110个子文件)
.classpath 1KB
supervisord_back.conf 12KB
supervisord.conf 12KB
all_dir_flume_to_pg_and_file.conf 3KB
flume_arvo_to_pg_and_file.conf 2KB
all_dir_flume_to_kafka.conf 2KB
all_dir_flume_to_kafka2.conf 2KB
all_dir_flume_to_pg.conf 2KB
dir_all_to_flume_gdata.conf 2KB
new.conf 2KB
es_db_x1_dir_flume_back.conf 2KB
x1_dir_flume_to_kafka.conf 1KB
x1_dir_to_db_flume.conf 1KB
flume_to_hbase.conf 1KB
flume_kafka_to_hdfs.conf 1KB
es_db_x1_dir_flume.conf 1KB
log_flume_to_hbase.conf 1KB
x1_dir_to_db_flume.conf 1021B
x1_dir_to_db_flume.conf 1020B
x2_dir_to_db_flume.conf 981B
x2_dir_to_db_flume.conf 980B
x4_dir_to_db_flume.conf 948B
x3_dir_to_db_flume.conf 948B
x9_dir_to_db_flume.conf 948B
x4_dir_to_db_flume.conf 947B
x8_dir_to_db_flume.conf 947B
x3_dir_to_db_flume.conf 947B
x8_dir_to_db_flume.conf 947B
x9_dir_to_db_flume.conf 947B
db_flumex1.conf 946B
db_flumex2.conf 918B
.gitignore 9B
elasticsearch-0.90.1.jar 10.44MB
elasticsearch-5.0.0.jar 8.99MB
hbase-protocol-1.3.1.jar 4.29MB
hadoop-common-2.5.1.jar 2.83MB
guava-19.0.jar 2.2MB
lucene-core-4.3.0.jar 2.11MB
netty-all-4.0.24.Final.jar 1.7MB
htrace-core-3.1.0-incubating.jar 1.41MB
hbase-client-1.3.1.jar 1.27MB
netty-3.9.4.Final.jar 1.25MB
zookeeper-3.4.6.jar 774KB
httpclient-4.5.2.jar 719KB
postgresql-9.4.1210.jre7.jar 658KB
hbase-common-1.3.1.jar 577KB
fastjson-1.2.29.jar 450KB
httpclient-4.2.1.jar 417KB
httpcore-nio-4.4.5.jar 348KB
httpcore-4.4.5.jar 320KB
commons-configuration-1.6.jar 292KB
foundation-service-2.5.0.jar 289KB
cat-client-1.4.0.jar 226KB
plexus-utils-3.0.2.jar 221KB
plexus-container-default-1.6.jar 218KB
httpcore-4.1.3.jar 177KB
httpasyncclient-4.1.2.jar 173KB
xbean-reflect-3.7.jar 145KB
aspectjrt-1.5.4.jar 112KB
hadoop-auth-2.5.1.jar 51KB
plexus-classworlds-2.5.1.jar 49KB
rest-5.5.0.jar 34KB
HBaseSink.java 22KB
AvroSinkExitTest2.java 20KB
AvroSinkExt.java 17KB
ExtendsEsRestSink.java 17KB
ExtendsEsHttpSink.java 16KB
TransportExtendsSink.java 16KB
DBsqlSink.java 10KB
JsonDBsqlSink.java 10KB
PgSqlSinkBack.java 9KB
PgSqlSink.java 8KB
EsHttpClientExt.java 8KB
AvroSinkExitTest.java 7KB
ElasticSearchTransportClientExt.java 7KB
ExtSimpleHbaseEventSerializer.java 7KB
ConverData.java 7KB
EsRestClientExt.java 7KB
ConverDataYH.java 6KB
ConverDataObject.java 6KB
ExtSimpleAsyncHbaseEventSerializer.java 5KB
ConverDataInterceptor.java 4KB
DatePathManager.java 3KB
EsUtil.java 1KB
Main.java 1KB
TestMain.java 738B
Mains.java 213B
README.md 2KB
mon 58B
org.eclipse.jdt.core.prefs 723B
org.eclipse.core.resources.prefs 150B
org.eclipse.m2e.core.prefs 86B
.project 668B
justone-kafka-sink-pg-json-connector.properties 2KB
justone-kafka-sink-pg-json-standalone.properties 2KB
app.properties 23B
pg_connect.sh 176B
x4_dir.sh 162B
x8_dir.sh 162B
x2_dir.sh 162B
共 110 条
- 1
- 2
资源评论
tafan
- 粉丝: 34
- 资源: 4652
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功