Skip navigation links

Apache Apex Malhar 3.8.1-SNAPSHOT API

Packages 
Package Description
com.datatorrent.apps.copy  
com.datatorrent.apps.logstream
Streaming log processing application.
com.datatorrent.apps.logstream.PropertyRegistry  
com.datatorrent.benchmark
Apex malhar performance demonstration application.
com.datatorrent.benchmark.aerospike  
com.datatorrent.benchmark.algo  
com.datatorrent.benchmark.cassandra  
com.datatorrent.benchmark.fs  
com.datatorrent.benchmark.hive  
com.datatorrent.benchmark.kafka  
com.datatorrent.benchmark.script  
com.datatorrent.benchmark.spillable  
com.datatorrent.benchmark.state  
com.datatorrent.benchmark.stream  
com.datatorrent.benchmark.testbench  
com.datatorrent.benchmark.window  
com.datatorrent.contrib.accumulo
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.aerospike
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.apachelog
Apache log application, operators, and utilities.
com.datatorrent.contrib.apachelog.zmq  
com.datatorrent.contrib.avro  
com.datatorrent.contrib.cassandra
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.couchbase
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.couchdb
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.elasticsearch
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.enrich  
com.datatorrent.contrib.formatter  
com.datatorrent.contrib.geode  
com.datatorrent.contrib.hbase
HBase operators and utilities.
com.datatorrent.contrib.hive
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.jython
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.kafka
Kafka operators and utilities.
com.datatorrent.contrib.kinesis
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.memcache
Memcache operators and utilities.
com.datatorrent.contrib.memcache_whalin
Memcache operators and utilities using whalin library.
com.datatorrent.contrib.memsql
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.mongodb
MongoDB operators and utilities.
com.datatorrent.contrib.mqtt
MQTT operators and utilities.
com.datatorrent.contrib.nifi  
com.datatorrent.contrib.parquet  
com.datatorrent.contrib.parser
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.r
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.rabbitmq
RabbitMQ operators and utilities.
com.datatorrent.contrib.redis
Redis operators and utilities.
com.datatorrent.contrib.romesyndication
Rome operators and utilities.
com.datatorrent.contrib.ruby  
com.datatorrent.contrib.solr
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.splunk
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.contrib.sqlite
SQLite operators and utilities.
com.datatorrent.contrib.twitter  
com.datatorrent.contrib.zmq
ZeroMQ operators and utilities.
com.datatorrent.lib.algo
Library of algorithmic operators
com.datatorrent.lib.appdata
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.lib.appdata.datastructs  
com.datatorrent.lib.appdata.gpo  
com.datatorrent.lib.appdata.query  
com.datatorrent.lib.appdata.query.serde  
com.datatorrent.lib.appdata.schemas  
com.datatorrent.lib.appdata.snapshot  
com.datatorrent.lib.bandwidth  
com.datatorrent.lib.codec
Shared codec implementations.
com.datatorrent.lib.converter
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.lib.counters
Basic counters and aggregates implementations.
com.datatorrent.lib.db
Library of interface for database adapters
com.datatorrent.lib.db.cache
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.lib.db.jdbc
JDBC operators and utilities.
com.datatorrent.lib.expression  
com.datatorrent.lib.fileaccess
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.lib.filter  
com.datatorrent.lib.formatter  
com.datatorrent.lib.io
Library of input operators for writing into streams and output operators for reading from streams.
com.datatorrent.lib.io.block
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.lib.io.fs
Library of input operators for writing into file streams and output operators for reading from file streams.
com.datatorrent.lib.io.jms
Library of input operators for writing into jms broker and output operators for reading from jms broker.
com.datatorrent.lib.join  
com.datatorrent.lib.logs
Library of log line processing operators.
com.datatorrent.lib.math
Library of arithmetic operators.
com.datatorrent.lib.metric
This package contains simple physical metrics aggregators.
com.datatorrent.lib.metric.max  
com.datatorrent.lib.metric.min  
com.datatorrent.lib.multiwindow
Library of multi-window operators including sliding window.
com.datatorrent.lib.parser
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.lib.partitioner
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.lib.projection  
com.datatorrent.lib.script
Library of operators for scripting languages, including Bash, JavaScript, and Python.
com.datatorrent.lib.statistics
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
com.datatorrent.lib.stream
Library of operators for stream operations
com.datatorrent.lib.streamquery.condition  
com.datatorrent.lib.streamquery.index  
com.datatorrent.lib.testbench
Library of test bench modules.
com.datatorrent.lib.transform  
com.datatorrent.lib.util
Library of shared operators and utilities.
com.datatorrent.lib.util.comparator  
com.datatorrent.lib.util.time  
com.datatorrent.lib.xml  
com.datatorrent.samples
com.datatorrent.lib.samplecode is a collection of libraries that have examples of various operators
com.datatorrent.samples.lib.algo
com.datatorrent.lib.samplecode.algo is a library of examples of usage of algorithmic operators
com.datatorrent.samples.lib.io
com.datatorrent.lib.samplecode.io is a library samples of usages of operators from io library
com.datatorrent.samples.lib.math
com.datatorrent.lib.samplecode.math is a library examples of usages of operators from math library
org.apache.apex.examples.csvformatter  
org.apache.apex.examples.dedup  
org.apache.apex.examples.distributeddistinct  
org.apache.apex.examples.dynamic  
org.apache.apex.examples.echoserver  
org.apache.apex.examples.enricher  
org.apache.apex.examples.exactlyonce  
org.apache.apex.examples.FileToJdbcApp  
org.apache.apex.examples.filter  
org.apache.apex.examples.frauddetect  
org.apache.apex.examples.frauddetect.operator  
org.apache.apex.examples.frauddetect.util  
org.apache.apex.examples.ftp
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.examples.iteration
Iteration demonstration application.
org.apache.apex.examples.JdbcIngest  
org.apache.apex.examples.JdbcToJdbc  
org.apache.apex.examples.kafka.exactlyonceoutput  
org.apache.apex.examples.kafka.hdfs2kafka  
org.apache.apex.examples.kafka.kafka2hdfs  
org.apache.apex.examples.machinedata  
org.apache.apex.examples.machinedata.data  
org.apache.apex.examples.machinedata.operator  
org.apache.apex.examples.machinedata.util  
org.apache.apex.examples.mobile
Mobile phones tracking demonstration application.
org.apache.apex.examples.mrmonitor  
org.apache.apex.examples.mroperator  
org.apache.apex.examples.nyctaxi  
org.apache.apex.examples.partition  
org.apache.apex.examples.pi
Pi calculation demonstration application.
org.apache.apex.examples.r.oldfaithful  
org.apache.apex.examples.recordReader  
org.apache.apex.examples.s3Output  
org.apache.apex.examples.s3ToHdfsSync  
org.apache.apex.examples.s3TupleOutput  
org.apache.apex.examples.throttle  
org.apache.apex.examples.transform  
org.apache.apex.examples.twitter
Twitter top URL's demonstration application.
org.apache.apex.examples.uniquecount
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.examples.wordcount
Streaming word count demonstration application.
org.apache.apex.examples.yahoofinance
Yahoo Finance demonstration applications.
org.apache.apex.malhar.contrib.misc.algo  
org.apache.apex.malhar.contrib.misc.math  
org.apache.apex.malhar.contrib.misc.streamquery
Library of operators for streaming query language.
org.apache.apex.malhar.contrib.misc.streamquery.condition  
org.apache.apex.malhar.contrib.misc.streamquery.function  
org.apache.apex.malhar.contrib.misc.streamquery.index  
org.apache.apex.malhar.contrib.parser
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.contrib.parser.log  
org.apache.apex.malhar.flume.discovery  
org.apache.apex.malhar.flume.interceptor  
org.apache.apex.malhar.flume.operator  
org.apache.apex.malhar.flume.sink  
org.apache.apex.malhar.flume.source  
org.apache.apex.malhar.flume.storage  
org.apache.apex.malhar.hive  
org.apache.apex.malhar.kafka  
org.apache.apex.malhar.kudu
Kudu package contains the Operator implementations for both input and output.
org.apache.apex.malhar.kudu.partitioner
The partitioner package classes are responsible for creating the right number of Apex operators for a given kudu table that is being scanned.
org.apache.apex.malhar.kudu.scanner
The scanner package holds classes responsible scanning kudu tablets as per the provided predicates.
org.apache.apex.malhar.kudu.sqlparser  
org.apache.apex.malhar.kudu.sqltranslator
The sqltranslator package classes are responsible for constructing Kudu predicates given a SQL expression as input.
org.apache.apex.malhar.lib.appdata  
org.apache.apex.malhar.lib.db.redshift  
org.apache.apex.malhar.lib.dedup  
org.apache.apex.malhar.lib.dimensions
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.dimensions.aggregator  
org.apache.apex.malhar.lib.fs  
org.apache.apex.malhar.lib.fs.s3  
org.apache.apex.malhar.lib.function  
org.apache.apex.malhar.lib.io.block  
org.apache.apex.malhar.lib.join  
org.apache.apex.malhar.lib.state
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.state.managed
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.state.spillable
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.state.spillable.inmem  
org.apache.apex.malhar.lib.state.spillable.managed  
org.apache.apex.malhar.lib.utils
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.utils.serde
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.wal
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.window
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.window.accumulation
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.lib.window.impl
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.apex.malhar.sql  
org.apache.apex.malhar.sql.codegen  
org.apache.apex.malhar.sql.operators  
org.apache.apex.malhar.sql.planner  
org.apache.apex.malhar.sql.sample  
org.apache.apex.malhar.sql.schema  
org.apache.apex.malhar.sql.table  
org.apache.apex.malhar.stream.api  
org.apache.apex.malhar.stream.api.impl  
org.apache.apex.malhar.stream.sample  
org.apache.apex.malhar.stream.sample.complete  
org.apache.apex.malhar.stream.sample.cookbook  
org.apache.hadoop.io.file.tfile
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Skip navigation links

Copyright © 2015-2018 Apache Software Foundation. All Rights Reserved.