Repository: apex-malhar Updated Branches: refs/heads/release-3.6 1a9c75be9 -> e471011aa
Add @since tags and update change log for release 3.6.0 Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/be4db917 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/be4db917 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/be4db917 Branch: refs/heads/release-3.6 Commit: be4db917dec5743476994fb7557a0a59cf1c1e70 Parents: 1a9c75b Author: Apex Dev <[email protected]> Authored: Sat Nov 26 15:25:47 2016 -0800 Committer: Thomas Weise <[email protected]> Committed: Fri Dec 2 13:24:04 2016 -0800 ---------------------------------------------------------------------- CHANGELOG.md | 84 ++++++++++++++++++++ .../spillable/SpillableBenchmarkApp.java | 3 + .../spillable/SpillableTestInputOperator.java | 3 + .../spillable/SpillableTestOperator.java | 3 + .../state/ManagedStateBenchmarkApp.java | 3 + .../benchmark/state/StoreOperator.java | 3 + .../cassandra/AbstractUpsertOutputOperator.java | 7 +- .../contrib/cassandra/CassandraPojoUtils.java | 8 +- .../CassandraPreparedStatementGenerator.java | 4 +- .../cassandra/ConnectionStateManager.java | 2 + .../cassandra/UpsertExecutionContext.java | 2 + .../contrib/enrich/FixedWidthFSLoader.java | 2 + .../misc/streamquery/GroupByHavingOperator.java | 3 + .../AbstractUpsertOutputOperatorCodecsTest.java | 2 +- .../sql/sample/FusionStyleSQLApplication.java | 3 + .../sql/sample/PureStyleSQLApplication.java | 3 + .../sql/sample/SQLApplicationWithAPI.java | 3 + .../sql/sample/SQLApplicationWithModelFile.java | 3 + .../lib/state/managed/BucketProvider.java | 2 + .../malhar/lib/state/managed/TimeExtractor.java | 2 + ...agedTimeUnifiedStateSpillableStateStore.java | 2 + .../apex/malhar/lib/utils/ClassLoaderUtils.java | 3 + .../utils/serde/AffixKeyValueSerdeManager.java | 2 + .../apex/malhar/lib/utils/serde/AffixSerde.java | 2 + .../apex/malhar/lib/utils/serde/ArraySerde.java | 3 + .../apex/malhar/lib/utils/serde/Block.java | 2 + .../lib/utils/serde/BlockReleaseStrategy.java | 2 + .../malhar/lib/utils/serde/BlockStream.java | 2 + .../malhar/lib/utils/serde/BufferSlice.java | 2 + .../serde/DefaultBlockReleaseStrategy.java | 2 + .../malhar/lib/utils/serde/GenericSerde.java | 2 + .../utils/serde/KeyValueByteStreamProvider.java | 2 + .../lib/utils/serde/KeyValueSerdeManager.java | 3 + .../apex/malhar/lib/utils/serde/PairSerde.java | 2 + .../lib/utils/serde/SerializationBuffer.java | 3 + .../lib/utils/serde/WindowCompleteListener.java | 3 + .../lib/utils/serde/WindowedBlockStream.java | 2 + .../lib/window/WindowedMergeOperator.java | 2 + .../malhar/lib/window/accumulation/CoGroup.java | 2 + .../lib/window/accumulation/InnerJoin.java | 2 + .../lib/window/accumulation/PojoInnerJoin.java | 2 + .../impl/KeyedWindowedMergeOperatorImpl.java | 2 + .../impl/SpillableSessionWindowedStorage.java | 2 + .../impl/SpillableWindowedKeyedStorage.java | 2 + .../impl/SpillableWindowedPlainStorage.java | 2 + .../window/impl/WindowKeyPairTimeExtractor.java | 2 + .../lib/window/impl/WindowTimeExtractor.java | 2 + .../window/impl/WindowedMergeOperatorImpl.java | 2 + .../apex/malhar/sql/SQLExecEnvironment.java | 2 + .../malhar/sql/codegen/BeanClassGenerator.java | 2 + .../malhar/sql/codegen/ExpressionCompiler.java | 2 + .../sql/operators/FilterTransformOperator.java | 2 + .../malhar/sql/operators/InnerJoinOperator.java | 2 + .../apex/malhar/sql/operators/LineReader.java | 2 + .../malhar/sql/operators/OperatorUtils.java | 3 + .../apex/malhar/sql/planner/ApexRelNode.java | 2 + .../apache/apex/malhar/sql/planner/RelInfo.java | 2 + .../apex/malhar/sql/planner/RelNodeVisitor.java | 2 + .../apex/malhar/sql/schema/ApexSQLTable.java | 2 + .../malhar/sql/schema/ApexSQLTableFactory.java | 3 + .../malhar/sql/schema/TupleSchemaRegistry.java | 3 + .../apex/malhar/sql/table/CSVMessageFormat.java | 3 + .../apache/apex/malhar/sql/table/Endpoint.java | 2 + .../apex/malhar/sql/table/FileEndpoint.java | 2 + .../apex/malhar/sql/table/KafkaEndpoint.java | 2 + .../apex/malhar/sql/table/MessageFormat.java | 2 + .../apex/malhar/sql/table/StreamEndpoint.java | 2 + 67 files changed, 240 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/CHANGELOG.md ---------------------------------------------------------------------- diff --git a/CHANGELOG.md b/CHANGELOG.md index 447a70a..f9f5354 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,6 +1,90 @@ Apex Malhar Changelog ======================================================================================================================== +Version 3.6.0 - 2016-11-30 +------------------------------------------------------------------------------------------------------------------------ + +### Sub-task +* [APEXMALHAR-2244] - Optimize WindowedStorage and Spillable data structures for time series +* [APEXMALHAR-2248] - Create SpillableSet and SpillableSetMultimap interfaces and implementation + +### Bug +* [APEXMALHAR-1852] - File Splitter Test Failing +* [APEXMALHAR-2176] - expressionFunctions for FilterOperator throws IndexOutOfBounds +* [APEXMALHAR-2207] - JsonFormatterTest application test should check for presence of expected results +* [APEXMALHAR-2217] - Remove some redundant code in WindowedStorage and WindowedKeyedStorage +* [APEXMALHAR-2224] - GenericFileOutputOperator rotateCall fails if no data is written to the file +* [APEXMALHAR-2226] - Not suppported Exception in AbstractFileOutput Operator. +* [APEXMALHAR-2227] - Error while connecting with Kafka using Apache Apex +* [APEXMALHAR-2236] - Potential NullPointerException in JdbcStore +* [APEXMALHAR-2245] - WindowBoundedMapCache.remove not working when key not in cache +* [APEXMALHAR-2246] - Key of SpillableByteArrayListMultimapImpl not comparable +* [APEXMALHAR-2256] - POJOInnerJoinOperator should use getDeclaredField of java reflection +* [APEXMALHAR-2258] - JavaExpressionParser does not cast type correctly when expression is binary +* [APEXMALHAR-2263] - Offsets in AbstractFileInputOperator should be long rather than int +* [APEXMALHAR-2265] - Add entries to mkdocs.yml for recently added operator docs +* [APEXMALHAR-2272] - sequentialFileRead property on FSInputModule not functioning as expected +* [APEXMALHAR-2273] - Retraction trigger is fired incorrectly when fireOnlyUpdatedPanes is true +* [APEXMALHAR-2276] - ManagedState: value of a key does not get over-written in the same time bucket +* [APEXMALHAR-2281] - ManagedState: race condition with put & asyncGet +* [APEXMALHAR-2290] - JDBCPOJOInsertOutput Operator - Optimization to populate metadata from database +* [APEXMALHAR-2291] - Exactly-once processing not working correctly for JdbcPOJOInsertOutputOperator +* [APEXMALHAR-2299] - TimeBasedDedupOperator throws exception during time bucket assignment in certain edge cases +* [APEXMALHAR-2305] - Change implementation of session window to reflect what is described in streaming 102 blog +* [APEXMALHAR-2307] - Session windows are not deleted properly after merge or extend +* [APEXMALHAR-2309] - TimeBasedDedupOperator marks new tuples as duplicates if expired tuples exist +* [APEXMALHAR-2312] - NullPointerException in FileSplitterInput when file path is specified +* [APEXMALHAR-2314] - Improper functioning in partitioning of sequentialFileRead property of FSRecordReader +* [APEXMALHAR-2315] - Ignore Join Test for because of issues in POJOInnerJoinOperator +* [APEXMALHAR-2317] - Change SpillableBenchmarkApp to adapt the change on Spillable Data Structure +* [APEXMALHAR-2325] - Same block id is emitting from FSInputModule +* [APEXMALHAR-2329] - ManagedState benchmark should not use constant bucket +* [APEXMALHAR-2333] - StateTracker#run throws NoSuchElementException +* [APEXMALHAR-2334] - Managed State benchmark: blocked committed window +* [APEXMALHAR-2342] - Fix null pointer exception in AbstractFileOutputOperator setup +* [APEXMALHAR-2351] - Exception while fetching properties for Operators using JdbcStore +* [APEXMALHAR-2353] - timeExpression should not be null for time based Dedup + +### Documentation +* [APEXMALHAR-2166] - Add user documentation for Json Parser +* [APEXMALHAR-2167] - Add user documentation for Json Formatter +* [APEXMALHAR-2179] - Add documentation for JDBCPollInputOperator +* [APEXMALHAR-2184] - Add documentation for FileSystem Input Operator +* [APEXMALHAR-2219] - Add documentation for Deduper +* [APEXMALHAR-2232] - Add documentation for csv parser +* [APEXMALHAR-2242] - Add documentation for 0.9 version of Kafka Input Operator. +* [APEXMALHAR-2257] - Add documentation for Transform operator +* [APEXMALHAR-2264] - Add documentation for jmsInputOperator +* [APEXMALHAR-2282] - Document Windowed Operator and Accumulation + +### Improvement +* [APEXMALHAR-2017] - Use pre checkpoint notification to optimize operator IO +* [APEXMALHAR-2139] - UniqueCounter changes +* [APEXMALHAR-2237] - Dynamic partitioning support for FSInputModule +* [APEXMALHAR-2267] - Remove the word "Byte" in the spillable data structures because it's implied +* [APEXMALHAR-2280] - Add InterfaceStability annotations to all windowed operator related packages +* [APEXMALHAR-2302] - Exposing more properties of FSSplitter and BlockReader operators to FSRecordReaderModule +* [APEXMALHAR-2320] - FSWindowDataManager.toSlice() can cause lots of garbage collection +* [APEXMALHAR-2327] - BucketsFileSystem.writeBucketData() call Slice.toByteArray() cause allocate unnecessary memory +* [APEXMALHAR-2340] - Initialize the list of JdbcFieldInfo in JdbcPOJOInsertOutput from properties.xml + +### New Feature +* [APEXMALHAR-1818] - Integrate Calcite to support SQL +* [APEXMALHAR-2152] - Enricher - Add fixed length file format support to FSLoader +* [APEXMALHAR-2181] - Non-Transactional Prepared Statement Based Cassandra Upsert (Update + Insert ) output Operator +* [APEXMALHAR-2209] - Add inner join example application to examples repository +* [APEXMALHAR-2229] - Add support for peek on com.datatorrent.lib.fileaccess.FileAccess.FileReader +* [APEXMALHAR-2247] - Add iteration feature in SpillableArrayListImpl and generalize SerdeListSlice to SerdeCollectionSlice +* [APEXMALHAR-2304] - Apex SQL: Add examples for SQL in Apex in demos folder + +### Task +* [APEXMALHAR-2143] - Evaluate and retire lib/math, lib/algo, and lib/streamquery operators +* [APEXMALHAR-2190] - Use reusable buffer to serial spillable data structure +* [APEXMALHAR-2201] - Suppress console output in Stream API tests +* [APEXMALHAR-2225] - Upgrade checkstyle rules to 1.1.0 and fix trailing whitespace +* [APEXMALHAR-2240] - Implement Windowed Join Operator +* [APEXMALHAR-2338] - Couple of links in fsInputOperator.md have a stray # which prevents proper display + Version 3.5.0 - 2016-08-31 ------------------------------------------------------------------------------------------------------------------------ http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableBenchmarkApp.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableBenchmarkApp.java b/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableBenchmarkApp.java index e2fe8bb..300ea64 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableBenchmarkApp.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableBenchmarkApp.java @@ -29,6 +29,9 @@ import com.datatorrent.api.annotation.ApplicationAnnotation; import com.datatorrent.lib.fileaccess.TFileImpl; @ApplicationAnnotation(name = "SpillableBenchmarkApp") +/** + * @since 3.6.0 + */ public class SpillableBenchmarkApp implements StreamingApplication { protected final String PROP_STORE_PATH = "dt.application.SpillableBenchmarkApp.storeBasePath"; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestInputOperator.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestInputOperator.java b/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestInputOperator.java index c3eafb0..9bee9a6 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestInputOperator.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestInputOperator.java @@ -22,6 +22,9 @@ import com.datatorrent.api.DefaultOutputPort; import com.datatorrent.api.InputOperator; import com.datatorrent.common.util.BaseOperator; +/** + * @since 3.6.0 + */ public class SpillableTestInputOperator extends BaseOperator implements InputOperator { public final transient DefaultOutputPort<String> output = new DefaultOutputPort<String>(); http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestOperator.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestOperator.java b/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestOperator.java index 7c87b93..07ab02e 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestOperator.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/spillable/SpillableTestOperator.java @@ -35,6 +35,9 @@ import com.datatorrent.api.Operator; import com.datatorrent.api.Operator.ShutdownException; import com.datatorrent.common.util.BaseOperator; +/** + * @since 3.6.0 + */ public class SpillableTestOperator extends BaseOperator implements Operator.CheckpointNotificationListener { private static final Logger logger = LoggerFactory.getLogger(SpillableTestOperator.class); http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/benchmark/src/main/java/com/datatorrent/benchmark/state/ManagedStateBenchmarkApp.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/state/ManagedStateBenchmarkApp.java b/benchmark/src/main/java/com/datatorrent/benchmark/state/ManagedStateBenchmarkApp.java index be615d0..ae5ba40 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/state/ManagedStateBenchmarkApp.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/state/ManagedStateBenchmarkApp.java @@ -47,6 +47,9 @@ import com.datatorrent.lib.fileaccess.TFileImpl; import com.datatorrent.lib.util.KeyValPair; @ApplicationAnnotation(name = "ManagedStateBenchmark") +/** + * @since 3.6.0 + */ public class ManagedStateBenchmarkApp implements StreamingApplication { protected static final String PROP_STORE_PATH = "dt.application.ManagedStateBenchmark.storeBasePath"; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/benchmark/src/main/java/com/datatorrent/benchmark/state/StoreOperator.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/state/StoreOperator.java b/benchmark/src/main/java/com/datatorrent/benchmark/state/StoreOperator.java index f960d15..74ba658 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/state/StoreOperator.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/state/StoreOperator.java @@ -38,6 +38,9 @@ import com.datatorrent.common.util.BaseOperator; import com.datatorrent.lib.util.KeyValPair; import com.datatorrent.netlet.util.Slice; +/** + * @since 3.6.0 + */ public class StoreOperator extends BaseOperator implements Operator.CheckpointNotificationListener { private static final Logger logger = LoggerFactory.getLogger(StoreOperator.class); http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperator.java index 95f98fe..b790492 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperator.java @@ -124,6 +124,8 @@ import static com.google.common.base.Preconditions.checkNotNull; * 13. Support for handling Nulls i.e. whether null values in the POJO are to be persisted as is or to be ignored so * that the application need not perform a read to populate a POJO field if it is not available in the context * 14. A few autometrics are provided for monitoring the latency aspects of the cassandra cluster + * + * @since 3.6.0 */ @InterfaceStability.Evolving @@ -922,7 +924,7 @@ public abstract class AbstractUpsertOutputOperator extends BaseOperator implemen this.windowDataManager = windowDataManager; } - /*** + /** * Implementing concrete Operator instances define the Connection Builder properties by implementing this method * Please refer to {@link com.datatorrent.contrib.cassandra.ConnectionStateManager.ConnectionBuilder} for * an example implementation of the ConnectionStateManager instantiation. @@ -993,8 +995,7 @@ public abstract class AbstractUpsertOutputOperator extends BaseOperator implemen * @param windowId * @return Whether the current POJO that is being passed in should be allowed to write into the cassandra row just for * the reconciling window phase - ***/ - + */ abstract boolean reconcileRecord(Object T, long windowId); enum OperationContext http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPojoUtils.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPojoUtils.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPojoUtils.java index b1f5f4a..8b435c9 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPojoUtils.java +++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPojoUtils.java @@ -31,12 +31,14 @@ import com.datastax.driver.core.LocalDate; import com.datastax.driver.core.TypeCodec; import com.datatorrent.lib.util.PojoUtils; -/*** +/** * Used to manage simple data type based getters for given cassandra columns + * + * @since 3.6.0 */ public class CassandraPojoUtils { - /*** + /** * Resolves a getter that can be associated with the given field name in the Pojo matching to the given * data type of cassandra * @param tuplePayloadClass The tuple class that is used to build the getter from @@ -99,7 +101,7 @@ public class CassandraPojoUtils return getter; } - /*** + /** * Populates a given bound statement column with a value give a POJO and the map representing the getters * @param boundStatement The statement that needs to be populated with the value * @param getters A map mapping the applicable getter for a given column name as key http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPreparedStatementGenerator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPreparedStatementGenerator.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPreparedStatementGenerator.java index 355fccf..713179c 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPreparedStatementGenerator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/CassandraPreparedStatementGenerator.java @@ -32,8 +32,10 @@ import com.datastax.driver.core.DataType; import com.datastax.driver.core.PreparedStatement; import com.datastax.driver.core.Session; -/*** +/** * Used to generate CQL strings that can be used to generate prepared statements. + * + * @since 3.6.0 */ public class CassandraPreparedStatementGenerator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/contrib/src/main/java/com/datatorrent/contrib/cassandra/ConnectionStateManager.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/ConnectionStateManager.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/ConnectionStateManager.java index cfc2b46..b4fd21f 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/ConnectionStateManager.java +++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/ConnectionStateManager.java @@ -74,6 +74,8 @@ import static com.google.common.base.Preconditions.checkNotNull; * } * Please refer {@link ConnectionBuilder} for details about parameters that can be used to define the connection * and its default behaviour + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class ConnectionStateManager implements AutoCloseable, Serializable http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/contrib/src/main/java/com/datatorrent/contrib/cassandra/UpsertExecutionContext.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/UpsertExecutionContext.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/UpsertExecutionContext.java index 66d0b6c..65e4af2 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/cassandra/UpsertExecutionContext.java +++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/UpsertExecutionContext.java @@ -34,6 +34,8 @@ import com.datastax.driver.core.ConsistencyLevel; * See {@link ConnectionStateManager.ConnectionBuilder} to set the default TTL for all payload executions * 6. Override the default Consistency level to be used for the current mutation * See {@link ConnectionStateManager.ConnectionBuilder} for setting default consistency. + * + * @since 3.6.0 */ public class UpsertExecutionContext<T> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/contrib/src/main/java/com/datatorrent/contrib/enrich/FixedWidthFSLoader.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/enrich/FixedWidthFSLoader.java b/contrib/src/main/java/com/datatorrent/contrib/enrich/FixedWidthFSLoader.java index d37ce3e..2f54f66 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/enrich/FixedWidthFSLoader.java +++ b/contrib/src/main/java/com/datatorrent/contrib/enrich/FixedWidthFSLoader.java @@ -46,6 +46,8 @@ import com.datatorrent.contrib.parser.AbstractCsvParser.Field; * This implementation of {@link FSLoader} is used to load data from fixed width * file.User needs to set {@link FixedWidthFSLoader#fieldDescription} to specify * field information. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class FixedWidthFSLoader extends FSLoader http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/contrib/src/main/java/org/apache/apex/malhar/contrib/misc/streamquery/GroupByHavingOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/org/apache/apex/malhar/contrib/misc/streamquery/GroupByHavingOperator.java b/contrib/src/main/java/org/apache/apex/malhar/contrib/misc/streamquery/GroupByHavingOperator.java index 9999429..9b2eeda 100644 --- a/contrib/src/main/java/org/apache/apex/malhar/contrib/misc/streamquery/GroupByHavingOperator.java +++ b/contrib/src/main/java/org/apache/apex/malhar/contrib/misc/streamquery/GroupByHavingOperator.java @@ -33,6 +33,9 @@ import com.datatorrent.common.util.BaseOperator; import com.datatorrent.lib.streamquery.index.ColumnIndex; import com.datatorrent.lib.streamquery.condition.Condition; @Deprecated +/** + * @since 3.6.0 + */ public class GroupByHavingOperator extends BaseOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/contrib/src/test/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperatorCodecsTest.java ---------------------------------------------------------------------- diff --git a/contrib/src/test/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperatorCodecsTest.java b/contrib/src/test/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperatorCodecsTest.java index 87c783f..faf32a4 100644 --- a/contrib/src/test/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperatorCodecsTest.java +++ b/contrib/src/test/java/com/datatorrent/contrib/cassandra/AbstractUpsertOutputOperatorCodecsTest.java @@ -42,7 +42,7 @@ import static org.junit.Assert.assertTrue; public class AbstractUpsertOutputOperatorCodecsTest { - /*** + /** * The schema that is used * * http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/FusionStyleSQLApplication.java ---------------------------------------------------------------------- diff --git a/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/FusionStyleSQLApplication.java b/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/FusionStyleSQLApplication.java index 94b02db..80b997d 100644 --- a/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/FusionStyleSQLApplication.java +++ b/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/FusionStyleSQLApplication.java @@ -40,6 +40,9 @@ import com.datatorrent.contrib.parser.CsvParser; @ApplicationAnnotation(name = "FusionStyleSQLApplication") +/** + * @since 3.6.0 + */ public class FusionStyleSQLApplication implements StreamingApplication { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/PureStyleSQLApplication.java ---------------------------------------------------------------------- diff --git a/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/PureStyleSQLApplication.java b/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/PureStyleSQLApplication.java index 9a727a3..79295f9 100644 --- a/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/PureStyleSQLApplication.java +++ b/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/PureStyleSQLApplication.java @@ -29,6 +29,9 @@ import com.datatorrent.api.StreamingApplication; import com.datatorrent.api.annotation.ApplicationAnnotation; @ApplicationAnnotation(name = "PureStyleSQLApplication") +/** + * @since 3.6.0 + */ public class PureStyleSQLApplication implements StreamingApplication { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithAPI.java ---------------------------------------------------------------------- diff --git a/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithAPI.java b/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithAPI.java index 604332b..da4f563 100644 --- a/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithAPI.java +++ b/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithAPI.java @@ -28,6 +28,9 @@ import com.datatorrent.api.StreamingApplication; import com.datatorrent.api.annotation.ApplicationAnnotation; @ApplicationAnnotation(name = "SQLApplicationWithAPI") +/** + * @since 3.6.0 + */ public class SQLApplicationWithAPI implements StreamingApplication { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithModelFile.java ---------------------------------------------------------------------- diff --git a/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithModelFile.java b/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithModelFile.java index 2d22b18..4c90a82 100644 --- a/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithModelFile.java +++ b/demos/sql/src/main/java/org/apache/apex/malhar/sql/sample/SQLApplicationWithModelFile.java @@ -30,6 +30,9 @@ import com.datatorrent.api.StreamingApplication; import com.datatorrent.api.annotation.ApplicationAnnotation; @ApplicationAnnotation(name = "SQLApplicationWithModelFile") +/** + * @since 3.6.0 + */ public class SQLApplicationWithModelFile implements StreamingApplication { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/state/managed/BucketProvider.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/BucketProvider.java b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/BucketProvider.java index bbd18ac..fc836e5 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/BucketProvider.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/BucketProvider.java @@ -21,6 +21,8 @@ package org.apache.apex.malhar.lib.state.managed; /** * This interface declares methods to get bucket by bucket id * + * + * @since 3.6.0 */ public interface BucketProvider { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeExtractor.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeExtractor.java b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeExtractor.java index e70e80f..5d706db 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeExtractor.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeExtractor.java @@ -20,6 +20,8 @@ package org.apache.apex.malhar.lib.state.managed; /** * A way to extract time from data + * + * @since 3.6.0 */ public interface TimeExtractor<T> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/managed/ManagedTimeUnifiedStateSpillableStateStore.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/managed/ManagedTimeUnifiedStateSpillableStateStore.java b/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/managed/ManagedTimeUnifiedStateSpillableStateStore.java index 207cb31..9eef72f 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/managed/ManagedTimeUnifiedStateSpillableStateStore.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/state/spillable/managed/ManagedTimeUnifiedStateSpillableStateStore.java @@ -23,6 +23,8 @@ import org.apache.apex.malhar.lib.state.spillable.SpillableStateStore; /** * + * + * @since 3.6.0 */ public class ManagedTimeUnifiedStateSpillableStateStore extends ManagedTimeUnifiedStateImpl implements SpillableStateStore { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/ClassLoaderUtils.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/ClassLoaderUtils.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/ClassLoaderUtils.java index 855c21f..928ca09 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/ClassLoaderUtils.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/ClassLoaderUtils.java @@ -25,6 +25,9 @@ import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FSDataInputStream; @InterfaceStability.Evolving +/** + * @since 3.6.0 + */ public class ClassLoaderUtils { /** http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixKeyValueSerdeManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixKeyValueSerdeManager.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixKeyValueSerdeManager.java index 57638d8..fc6b875 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixKeyValueSerdeManager.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixKeyValueSerdeManager.java @@ -30,6 +30,8 @@ import com.datatorrent.netlet.util.Slice; * * @param <K> * @param <V> + * + * @since 3.6.0 */ public class AffixKeyValueSerdeManager<K, V> extends KeyValueSerdeManager<K, V> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixSerde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixSerde.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixSerde.java index 7504633..28f07ec 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixSerde.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/AffixSerde.java @@ -25,6 +25,8 @@ import com.esotericsoftware.kryo.io.Output; * AffixSerde provides serde for adding prefix or suffix * * @param <T> + * + * @since 3.6.0 */ public class AffixSerde<T> implements Serde<T> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ArraySerde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ArraySerde.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ArraySerde.java index 4b2a45b..4ace95c 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ArraySerde.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ArraySerde.java @@ -24,6 +24,9 @@ import com.esotericsoftware.kryo.io.Input; import com.esotericsoftware.kryo.io.Output; import com.google.common.base.Preconditions; +/** + * @since 3.6.0 + */ public class ArraySerde<T> implements Serde<T[]> { private Serde<T> itemSerde; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Block.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Block.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Block.java index c140962..4b621d1 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Block.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/Block.java @@ -27,6 +27,8 @@ import com.datatorrent.netlet.util.Slice; * * keep the information of one block * + * + * @since 3.6.0 */ public class Block { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockReleaseStrategy.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockReleaseStrategy.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockReleaseStrategy.java index f8a097e..53e592b 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockReleaseStrategy.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockReleaseStrategy.java @@ -23,6 +23,8 @@ package org.apache.apex.malhar.lib.utils.serde; * - Stream keep on reporting how many free blocks it has in certain frequent. usually at the end of each window * - Stream check how many block should release. Stream usually release the blocks but Stream can make its own decision * - Stream report how many blocks actually released + * + * @since 3.6.0 */ public interface BlockReleaseStrategy { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockStream.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockStream.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockStream.java index ee50f7d..6dc8a7d 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockStream.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BlockStream.java @@ -32,6 +32,8 @@ import com.datatorrent.netlet.util.Slice; * A stream is a collection of blocks * BlockStream avoids copying the data that are already exposed to the caller * + * + * @since 3.6.0 */ public class BlockStream extends OutputStream { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BufferSlice.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BufferSlice.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BufferSlice.java index 5d830fe..237115a 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BufferSlice.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/BufferSlice.java @@ -28,6 +28,8 @@ import com.datatorrent.netlet.util.Slice; * com.datatorrent.netlet.util.Slice has problem with the hashCode(), so * override here * + * + * @since 3.6.0 */ public class BufferSlice extends Slice { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/DefaultBlockReleaseStrategy.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/DefaultBlockReleaseStrategy.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/DefaultBlockReleaseStrategy.java index 365cbc3..29177cb 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/DefaultBlockReleaseStrategy.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/DefaultBlockReleaseStrategy.java @@ -24,6 +24,8 @@ import org.apache.commons.lang3.mutable.MutableInt; /** * This implementation get the minimum number of free blocks in the period to release. * + * + * @since 3.6.0 */ public class DefaultBlockReleaseStrategy implements BlockReleaseStrategy { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/GenericSerde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/GenericSerde.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/GenericSerde.java index 0fbb2ab..8501614 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/GenericSerde.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/GenericSerde.java @@ -30,6 +30,8 @@ import com.esotericsoftware.kryo.io.Output; * incompatible changes to the class being serialized. * * @param <T> The type being serialized + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class GenericSerde<T> implements Serde<T> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueByteStreamProvider.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueByteStreamProvider.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueByteStreamProvider.java index a7dfa7f..13b5046 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueByteStreamProvider.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueByteStreamProvider.java @@ -22,6 +22,8 @@ package org.apache.apex.malhar.lib.utils.serde; * This interface provides methods for stream for key/value. * The implementation can separate the stream for key and value or share the same one. * + * + * @since 3.6.0 */ public interface KeyValueByteStreamProvider { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueSerdeManager.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueSerdeManager.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueSerdeManager.java index 6fbe9fe..e74c7a3 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueSerdeManager.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/KeyValueSerdeManager.java @@ -23,6 +23,9 @@ import org.apache.apex.malhar.lib.state.managed.BucketProvider; import com.datatorrent.netlet.util.Slice; +/** + * @since 3.6.0 + */ public class KeyValueSerdeManager<K, V> { protected Serde<K> keySerde; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PairSerde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PairSerde.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PairSerde.java index 3190880..534bdf3 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PairSerde.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/PairSerde.java @@ -30,6 +30,8 @@ import com.google.common.base.Preconditions; /** * This is an implementation of {@link Serde} which serializes and deserializes pairs. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class PairSerde<T1, T2> implements Serde<Pair<T1, T2>> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerializationBuffer.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerializationBuffer.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerializationBuffer.java index f33f1e0..2d7c204 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerializationBuffer.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/SerializationBuffer.java @@ -24,6 +24,9 @@ import com.esotericsoftware.kryo.io.Output; import com.datatorrent.netlet.util.Slice; +/** + * @since 3.6.0 + */ public class SerializationBuffer extends Output implements WindowCompleteListener, WindowListener { /* http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowCompleteListener.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowCompleteListener.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowCompleteListener.java index d2d38a7..9abb056 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowCompleteListener.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowCompleteListener.java @@ -18,6 +18,9 @@ */ package org.apache.apex.malhar.lib.utils.serde; +/** + * @since 3.6.0 + */ public interface WindowCompleteListener { /** http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowedBlockStream.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowedBlockStream.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowedBlockStream.java index 53710f8..4b9ced8 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowedBlockStream.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/WindowedBlockStream.java @@ -35,6 +35,8 @@ import com.google.common.collect.Sets; /** * This is a stream which manages blocks and supports window related operations. * + * + * @since 3.6.0 */ public class WindowedBlockStream extends BlockStream implements WindowListener, WindowCompleteListener { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/WindowedMergeOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/WindowedMergeOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/window/WindowedMergeOperator.java index 4706302..4928bca 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/WindowedMergeOperator.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/WindowedMergeOperator.java @@ -20,6 +20,8 @@ package org.apache.apex.malhar.lib.window; /** * Interface for Merge Windowed Operator. + * + * @since 3.6.0 */ public interface WindowedMergeOperator<InputT1, InputT2> extends WindowedOperator<InputT1> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CoGroup.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CoGroup.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CoGroup.java index e22d582..2363a8b 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CoGroup.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CoGroup.java @@ -24,6 +24,8 @@ import java.util.Set; /** * CoGroup Join Accumulation. + * + * @since 3.6.0 */ public class CoGroup<T> extends InnerJoin<T> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/InnerJoin.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/InnerJoin.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/InnerJoin.java index fd250a2..7f0dade 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/InnerJoin.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/InnerJoin.java @@ -27,6 +27,8 @@ import org.apache.apex.malhar.lib.window.MergeAccumulation; /** * Combine Join Accumulation, inner-joins tuples with same type from different streams. + * + * @since 3.6.0 */ public class InnerJoin<T> implements MergeAccumulation<T, T, List<Set<T>>, List<List<T>>> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoInnerJoin.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoInnerJoin.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoInnerJoin.java index 4b3bc69..f9cf91e 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoInnerJoin.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoInnerJoin.java @@ -32,6 +32,8 @@ import com.google.common.base.Throwables; /** * Inner join Accumulation for Pojo Streams. + * + * @since 3.6.0 */ public class PojoInnerJoin<InputT1, InputT2> implements MergeAccumulation<InputT1, InputT2, List<List<Map<String, Object>>>, List<Map<String, Object>>> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedMergeOperatorImpl.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedMergeOperatorImpl.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedMergeOperatorImpl.java index eeb4777..9accf25 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedMergeOperatorImpl.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/KeyedWindowedMergeOperatorImpl.java @@ -38,6 +38,8 @@ import com.datatorrent.lib.util.KeyValPair; * @param <InputT2> The type of the value of the keyed input tuple from second stream. * @param <AccumT> The type of the accumulated value in the operator state per key per window. * @param <OutputT> The type of the value of the keyed output tuple. + * + * @since 3.6.0 */ public class KeyedWindowedMergeOperatorImpl<KeyT, InputT1, InputT2, AccumT, OutputT> extends KeyedWindowedOperatorImpl<KeyT, InputT1, AccumT, OutputT> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableSessionWindowedStorage.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableSessionWindowedStorage.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableSessionWindowedStorage.java index b88501e..ef06eea 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableSessionWindowedStorage.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableSessionWindowedStorage.java @@ -37,6 +37,8 @@ import com.datatorrent.api.Context; /** * Spillable session windowed storage. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class SpillableSessionWindowedStorage<K, V> extends SpillableWindowedKeyedStorage<K, V> implements SessionWindowedStorage<K, V> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedKeyedStorage.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedKeyedStorage.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedKeyedStorage.java index d41c494..bf0c804 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedKeyedStorage.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedKeyedStorage.java @@ -41,6 +41,8 @@ import com.datatorrent.api.Context; * * @param <K> The key type * @param <V> The value type + * + * @since 3.6.0 */ public class SpillableWindowedKeyedStorage<K, V> implements WindowedStorage.WindowedKeyedStorage<K, V> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedPlainStorage.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedPlainStorage.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedPlainStorage.java index f9bbc17..f70771c 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedPlainStorage.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/SpillableWindowedPlainStorage.java @@ -35,6 +35,8 @@ import com.datatorrent.api.Context; * This is an implementation of WindowedPlainStorage that makes use of {@link Spillable} data structures * * @param <T> Type of the value per window + * + * @since 3.6.0 */ public class SpillableWindowedPlainStorage<T> implements WindowedStorage.WindowedPlainStorage<T> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowKeyPairTimeExtractor.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowKeyPairTimeExtractor.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowKeyPairTimeExtractor.java index ecf63a5..3242f7a 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowKeyPairTimeExtractor.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowKeyPairTimeExtractor.java @@ -25,6 +25,8 @@ import org.apache.commons.lang3.tuple.Pair; /** * A {@link TimeExtractor} to extract time from Pair of {@link Window} and key * The type of key doesn't matter in this case, so it assumes object as the key type + * + * @since 3.6.0 */ public class WindowKeyPairTimeExtractor<K> implements TimeExtractor<Pair<Window, K>> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowTimeExtractor.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowTimeExtractor.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowTimeExtractor.java index aee389a..603c90c 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowTimeExtractor.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowTimeExtractor.java @@ -23,6 +23,8 @@ import org.apache.apex.malhar.lib.window.Window; /** *ãA {@link TimeExtractor} to extract time from {@link Window} + * + * @since 3.6.0 */ public class WindowTimeExtractor implements TimeExtractor<Window> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedMergeOperatorImpl.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedMergeOperatorImpl.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedMergeOperatorImpl.java index 79475e3..d2594c1 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedMergeOperatorImpl.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/WindowedMergeOperatorImpl.java @@ -36,6 +36,8 @@ import com.datatorrent.api.annotation.InputPortFieldAnnotation; * @param <InputT2> The type of input tuple from first stream. * @param <AccumT> The type of the accumulated value in the operator state per key per window. * @param <OutputT> The type of output tuple. + * + * @since 3.6.0 */ public class WindowedMergeOperatorImpl<InputT1, InputT2, AccumT, OutputT> extends WindowedOperatorImpl<InputT1, AccumT, OutputT> implements WindowedMergeOperator<InputT1, InputT2> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/SQLExecEnvironment.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/SQLExecEnvironment.java b/sql/src/main/java/org/apache/apex/malhar/sql/SQLExecEnvironment.java index de146f6..8ce524b 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/SQLExecEnvironment.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/SQLExecEnvironment.java @@ -75,6 +75,8 @@ import com.datatorrent.api.DAG; * </pre> * * Above code will evaluate SQL statement and convert the resultant Relational Algebra to a sub-DAG. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class SQLExecEnvironment http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/codegen/BeanClassGenerator.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/codegen/BeanClassGenerator.java b/sql/src/main/java/org/apache/apex/malhar/sql/codegen/BeanClassGenerator.java index 3e384a2..5365e20 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/codegen/BeanClassGenerator.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/codegen/BeanClassGenerator.java @@ -47,6 +47,8 @@ import com.google.common.collect.Maps; /** * Creates a bean class on fly. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class BeanClassGenerator http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/codegen/ExpressionCompiler.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/codegen/ExpressionCompiler.java b/sql/src/main/java/org/apache/apex/malhar/sql/codegen/ExpressionCompiler.java index e12ff53..542d27f 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/codegen/ExpressionCompiler.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/codegen/ExpressionCompiler.java @@ -47,6 +47,8 @@ import com.google.common.collect.ImmutableList; /** * Converts calcite expression of type {@link RexNode} to quasi-Java expression which can be used * with {@link com.datatorrent.lib.util.PojoUtils} + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class ExpressionCompiler http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/operators/FilterTransformOperator.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/operators/FilterTransformOperator.java b/sql/src/main/java/org/apache/apex/malhar/sql/operators/FilterTransformOperator.java index 192c58b..586a3fc 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/operators/FilterTransformOperator.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/operators/FilterTransformOperator.java @@ -27,6 +27,8 @@ import com.datatorrent.lib.util.PojoUtils; /** * This is an extension of {@link TransformOperator} which also takes care of filtering tuples. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class FilterTransformOperator extends TransformOperator http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/operators/InnerJoinOperator.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/operators/InnerJoinOperator.java b/sql/src/main/java/org/apache/apex/malhar/sql/operators/InnerJoinOperator.java index 0b21898..a1950cd 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/operators/InnerJoinOperator.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/operators/InnerJoinOperator.java @@ -26,6 +26,8 @@ import com.datatorrent.api.Context; /** * This is an extension of {@link POJOInnerJoinOperator} operator which works over a global scope and * does not have time bound expiry of join tuples. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class InnerJoinOperator extends POJOInnerJoinOperator http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/operators/LineReader.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/operators/LineReader.java b/sql/src/main/java/org/apache/apex/malhar/sql/operators/LineReader.java index b0225f0..6c0cbfd 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/operators/LineReader.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/operators/LineReader.java @@ -31,6 +31,8 @@ import com.datatorrent.lib.io.fs.AbstractFileInputOperator; /** * This operator reads data from given file/folder in line by line fashion. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class LineReader extends AbstractFileInputOperator<byte[]> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/operators/OperatorUtils.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/operators/OperatorUtils.java b/sql/src/main/java/org/apache/apex/malhar/sql/operators/OperatorUtils.java index e5a1928..c67e8f3 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/operators/OperatorUtils.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/operators/OperatorUtils.java @@ -23,6 +23,9 @@ import org.apache.calcite.sql.type.SqlTypeName; import org.apache.hadoop.classification.InterfaceStability; @InterfaceStability.Evolving +/** + * @since 3.6.0 + */ public class OperatorUtils { private static int opCount = 1; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/planner/ApexRelNode.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/planner/ApexRelNode.java b/sql/src/main/java/org/apache/apex/malhar/sql/planner/ApexRelNode.java index 7a0d339..9d92f98 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/planner/ApexRelNode.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/planner/ApexRelNode.java @@ -64,6 +64,8 @@ import com.datatorrent.lib.io.ConsoleOutputOperator; /** * This class defines how to populate DAG of Apex for the relational nodes of SQL Calcite + * + * @since 3.6.0 */ @InterfaceStability.Evolving public abstract class ApexRelNode http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelInfo.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelInfo.java b/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelInfo.java index 29948ec..7455d49 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelInfo.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelInfo.java @@ -27,6 +27,8 @@ import com.datatorrent.api.Operator; /** * This object communicates stream and connection data between various stages of relational algebra. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class RelInfo http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelNodeVisitor.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelNodeVisitor.java b/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelNodeVisitor.java index 68343ce..5a2c1c1 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelNodeVisitor.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/planner/RelNodeVisitor.java @@ -35,6 +35,8 @@ import com.datatorrent.api.Operator; /** * This class is the main class that converts relational algebra to a sub-DAG. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class RelNodeVisitor http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTable.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTable.java b/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTable.java index 6d16f63..68a9745 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTable.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTable.java @@ -42,6 +42,8 @@ import com.google.common.collect.ImmutableList; * This is representation of Apex source/destination to Calcite's {@link StreamableTable} table. * Any table that gets registered with {@link org.apache.apex.malhar.sql.SQLExecEnvironment} * gets registered as {@link ApexSQLTable}. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class ApexSQLTable implements ScannableTable, StreamableTable http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTableFactory.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTableFactory.java b/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTableFactory.java index c18f854..75f60df 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTableFactory.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/schema/ApexSQLTableFactory.java @@ -32,6 +32,9 @@ import org.apache.calcite.schema.TableFactory; import org.apache.hadoop.classification.InterfaceStability; @InterfaceStability.Evolving +/** + * @since 3.6.0 + */ public class ApexSQLTableFactory implements TableFactory<Table> { @SuppressWarnings("unchecked") http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/schema/TupleSchemaRegistry.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/schema/TupleSchemaRegistry.java b/sql/src/main/java/org/apache/apex/malhar/sql/schema/TupleSchemaRegistry.java index 7924298..460fafb 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/schema/TupleSchemaRegistry.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/schema/TupleSchemaRegistry.java @@ -45,6 +45,9 @@ import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; @InterfaceStability.Evolving +/** + * @since 3.6.0 + */ public class TupleSchemaRegistry { public static final String FQCN_PACKAGE = "org.apache.apex.generated.schema."; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/table/CSVMessageFormat.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/table/CSVMessageFormat.java b/sql/src/main/java/org/apache/apex/malhar/sql/table/CSVMessageFormat.java index a96df65..533e55d 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/table/CSVMessageFormat.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/table/CSVMessageFormat.java @@ -38,6 +38,9 @@ import com.datatorrent.contrib.parser.CsvParser; import com.datatorrent.contrib.parser.DelimitedSchema; @InterfaceStability.Evolving +/** + * @since 3.6.0 + */ public class CSVMessageFormat implements MessageFormat { public static final String CSV_SCHEMA = "schema"; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/table/Endpoint.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/table/Endpoint.java b/sql/src/main/java/org/apache/apex/malhar/sql/table/Endpoint.java index 41a26de..c38d2aa 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/table/Endpoint.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/table/Endpoint.java @@ -32,6 +32,8 @@ import com.datatorrent.api.DAG; * This interface defines abstract table and how it should be operated with. * Endpoint interface can be implemented for any type of data source eg. Kafka, File, JDBC etc. * Implementation of Endpoint interface should define how the table should represented for both input OR output side. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public interface Endpoint http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/table/FileEndpoint.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/table/FileEndpoint.java b/sql/src/main/java/org/apache/apex/malhar/sql/table/FileEndpoint.java index cac32a4..5ded696 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/table/FileEndpoint.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/table/FileEndpoint.java @@ -37,6 +37,8 @@ import com.datatorrent.api.Operator; /** * This is an implementation of {@link Endpoint} which defined how data should be read/written to file system. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class FileEndpoint implements Endpoint http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/table/KafkaEndpoint.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/table/KafkaEndpoint.java b/sql/src/main/java/org/apache/apex/malhar/sql/table/KafkaEndpoint.java index 56419c3..57308a1 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/table/KafkaEndpoint.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/table/KafkaEndpoint.java @@ -40,6 +40,8 @@ import com.datatorrent.api.Operator; /** * This is an implementation of {@link Endpoint} which defined how data should be read/written from kafka messaging system + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class KafkaEndpoint implements Endpoint http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/table/MessageFormat.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/table/MessageFormat.java b/sql/src/main/java/org/apache/apex/malhar/sql/table/MessageFormat.java index 80fef93..efae1ff 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/table/MessageFormat.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/table/MessageFormat.java @@ -31,6 +31,8 @@ import com.datatorrent.api.DAG; /** * This interface defines how message should be parsed from input or formatted for output. * The implementation of this interface should define both parsing and formatting representation for data. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public interface MessageFormat http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be4db917/sql/src/main/java/org/apache/apex/malhar/sql/table/StreamEndpoint.java ---------------------------------------------------------------------- diff --git a/sql/src/main/java/org/apache/apex/malhar/sql/table/StreamEndpoint.java b/sql/src/main/java/org/apache/apex/malhar/sql/table/StreamEndpoint.java index 5462e42..e666a3f 100644 --- a/sql/src/main/java/org/apache/apex/malhar/sql/table/StreamEndpoint.java +++ b/sql/src/main/java/org/apache/apex/malhar/sql/table/StreamEndpoint.java @@ -37,6 +37,8 @@ import com.datatorrent.api.Operator; /** * This is an implementation of {@link Endpoint} which defined how data should be read/written to a Apex streaming port. + * + * @since 3.6.0 */ @InterfaceStability.Evolving public class StreamEndpoint implements Endpoint
