![]() ![]() This means configurations such as cat or tail -F are going to produce the desired results where as date will probably not - the former two commands produce streams of data where as the latter produces a single event and exits.(捕获命令的输出,并按行进行处理,当 logStdErr设为true时,也将捕获stderr的输出;) If the process exits for any reason, the source also exits and will produce no further data. The component type name, needs to be thriftĮxec source runs a given Unix command on start-up and expects that process to continuously produce data on standard out (stderr is simply discarded, unless property logStdErr is set to true). ![]() (通过Thrift sink和Thrift source,可以构成tired collection topologies;必要的属性都已加黑) Property Name When paired with the built-in ThriftSink on another (previous hop) Flume agent, it can create tiered collection topologies. Listens on Thrift port and receives events from external Thrift client streams. # This will deny the client on localhost be allow clients from any other ip # This will Allow the client on localhost be deny clients from any other ip Set this to true to enable ipFiltering for nettyĭefine N netty ipFilter pattern rules with this config. This is the path to a Java keystore file. You must also specify a “keystore” and a “keystore-password”. Set this to true to enable SSL encryption. The compression-type must match the compression-type of matching AvroSink Maximum number of worker threads to spawn The component type name, needs to be avro (Avro sink与Avro source可以构成tiered collection topologies;下表中,必须属性 加黑了) Property Name When paired with the built-in Avro Sink on another (previous hop) Flume agent, it can create tiered collection topologies. Listens on Avro port and receives events from external Avro client streams. ![]()
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |