Find file History
Permalink
..
Failed to load latest commit information.
cassandraInput SPOI-8304: Cassandra Input operator example (#35) Oct 12, 2016
cassandraOutput SPOI-8304: Cassandra Input operator example (#35) Oct 12, 2016
csvformatter SPOI-8793 Jan 9, 2017
dedup Updated malhar version to 3.5.0 Oct 12, 2016
dynamic-partition SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
enricher SPOI-8652 Example for Enricher Jul 26, 2016
exactly-once SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
fileIO-multiDir SPOI-8843: Updating artifactId of project Aug 10, 2016
fileIO-simple SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
fileIO SPOI-8840: Example application to use AbstractThroughputInputOpeartor Sep 2, 2016
fileOutput SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
fileToJdbc SPOI-8252 #resolve #comment Create a simple file to JDBC application Aug 1, 2016
filter SPOI-8656 filter example app Oct 17, 2016
hdfs-sync Updated groupId Oct 28, 2016
hdfs2kafka SPOI-8632 Example to read from HDFS and write to Kafka Jul 9, 2016
hdht SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
innerjoin SPOI-9032 Added sample application for Inner Join Sep 13, 2016
jdbcIngest SPOI-8548: Example to use jdbc poll input operator Sep 12, 2016
jdbcToJdbc SPOI-8251 jdbc to jdbc app Jul 14, 2016
jmsActiveMQ New JMS ActiveMQ example for our examples/tutorials Sep 19, 2016
jmsSqs SPOI-8863 New example for using jmsInput operator for reading from SQS Oct 10, 2016
kafka SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
maprapp SPOI-8514: MapR Example App - MapR Streams to MapR DB Jan 3, 2017
operatorTutorial SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
parser SPOI-8789 Adding example for fixed width parser Jan 10, 2017
partition SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
recordReader SPOI-8561 Record reader example app Sep 6, 2016
s3-to-hdfs-sync SPOI-8848 S3 to HDFS example app Oct 26, 2016
s3output SPOI-9236 Add example application for S3Output Module Dec 2, 2016
throttle Fixed throttler to send requests once per state change instead of rep… Nov 27, 2016
topnwords SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
transform SPOI-9079 Added sample application for transform operator Oct 10, 2016
unifiers SPOI-8537 Updated examples to apex 3.4.0 Jul 6, 2016
README.md Merge pull request #30 from venkateshkottapalli/SPOI-8793-csvformatte… Jan 10, 2017

README.md

Application Description
cassandra-input-app Example to show how to use Cassandra Input Operator.
cassandra-output-app Example to show how to use Cassandra Output Operator.
csvformatter Example to show how to use CsvFormatter to format POJOs to a delimited string.
dedup Example showing use of Dedup operator
dynamic-partition Example showing use of StatsListener with dynamic paritioning
enricher Shows how to enrich streaming data using external source
exactly-once Shows how to read from Kafka and write to JDBC or HDFS with exactly-once semantics
fileIO Shows how to implement high-performance file copy using partitioning and the file input and output operators. Also shows the use of a second port to send control information.
fileIO-multiDir Shows how to use the file input operator to monitor multiple directories by using custom partitioning
fileIO-simple Simple example to copy data from files in an input directory to rolling files in an output directory
fileOutput Show how to use partitioning on both the file output operator and the input operator
fileToJdbc Shows how to read files from HDFS, parse into POJOs and then insert into a table in MySQL.
hdht Shows how to use the HDHT operator.
hdfs2kafka Shows how to read from HDFS and write to a Kafka topic.
s3-to-hdfs-sync Copying files from Amazon S3 to HDFS
s3output Shows how to read files from HDFS and upload into S3 bucket.
innerjoin Shows how to use streaming innerjoin operator
jdbcIngest Shows how to read rows from a table in an SQL database, polling and non-polling fashion, and write them to a file in HDFS.
jdbcToJdbc This application reads from an input table using JDBC, converts input to user defined POJO & then writes those POJOS to another table.
jmsActiveMQ Shows how to use the JMS input operator to read from an ActiveMQ queue
jmsSqs Shows how to use the JMS input operator to read from an SQS queue
kafka Shows how to read from Kafka using the new 0.9 input operator and write to HDFS using rolling output files.
maprapp Shows how to read from MapR Streams using Kafka 0.9 input operator and write to MapR DB using HBase output operator.
operatorTutorial Simple example of a word-count operator and a unit test for it
parser Examples showing how to use different parsers and formatters
partition Shows use of custom partitioning with a stream codec.
recordReader Shows use of FSRecordReaderModule to read newline delimited records from a file.
throttle Shows use of OperatorRequest and StatsListener to modulate the speed of the input operator when downstream operators are unable to keep up.
topnwords The Top-N words example.
transform Example for Transform Operator.