APEXMALHAR-1950 #resolve #comment includes : 1. removed @Stable annotation from classes 2. add @Evolving to classes and packages
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/d570b8d6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/d570b8d6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/d570b8d6 Branch: refs/heads/master Commit: d570b8d6f178a8c00da3819407bda3aa466b9821 Parents: b7199b7 Author: Chandni Singh <[email protected]> Authored: Wed Jan 6 18:30:23 2016 -0800 Committer: Chandni Singh <[email protected]> Committed: Thu Jan 7 14:42:40 2016 -0800 ---------------------------------------------------------------------- .../contrib/accumulo/package-info.java | 20 +++++++++++++++++++ .../contrib/aerospike/package-info.java | 20 +++++++++++++++++++ .../contrib/apachelog/package-info.java | 1 + .../contrib/cassandra/package-info.java | 20 +++++++++++++++++++ .../contrib/couchbase/package-info.java | 20 +++++++++++++++++++ .../contrib/couchdb/package-info.java | 20 +++++++++++++++++++ .../contrib/elasticsearch/package-info.java | 20 +++++++++++++++++++ .../contrib/formatter/CsvFormatter.java | 3 +-- .../datatorrent/contrib/hbase/package-info.java | 7 ++++--- .../datatorrent/contrib/hive/package-info.java | 20 +++++++++++++++++++ .../contrib/jython/package-info.java | 20 +++++++++++++++++++ .../datatorrent/contrib/kafka/package-info.java | 3 --- .../contrib/kinesis/package-info.java | 20 +++++++++++++++++++ .../contrib/memcache/package-info.java | 7 ++++--- .../contrib/memcache_whalin/package-info.java | 7 ++++--- .../contrib/memsql/package-info.java | 20 +++++++++++++++++++ .../contrib/mongodb/package-info.java | 7 ++++--- .../datatorrent/contrib/mqtt/package-info.java | 1 + .../datatorrent/contrib/parser/CsvParser.java | 3 --- .../contrib/parser/package-info.java | 20 +++++++++++++++++++ .../com/datatorrent/contrib/r/package-info.java | 20 +++++++++++++++++++ .../contrib/rabbitmq/package-info.java | 7 ++++--- .../datatorrent/contrib/redis/package-info.java | 1 + .../contrib/romesyndication/package-info.java | 7 ++++--- .../datatorrent/contrib/ruby/RubyOperator.java | 1 + .../datatorrent/contrib/solr/package-info.java | 20 +++++++++++++++++++ .../contrib/splunk/package-info.java | 20 +++++++++++++++++++ .../contrib/sqlite/package-info.java | 7 ++++--- .../contrib/twitter/TwitterSampleInput.java | 1 + .../datatorrent/contrib/zmq/package-info.java | 7 ++++--- .../com/datatorrent/lib/algo/package-info.java | 2 +- .../datatorrent/lib/appdata/package-info.java | 20 +++++++++++++++++++ .../com/datatorrent/lib/codec/package-info.java | 2 +- .../datatorrent/lib/converter/package-info.java | 20 +++++++++++++++++++ .../datatorrent/lib/counters/package-info.java | 3 ++- ...nsactionableKeyValueStoreOutputOperator.java | 1 + ...egateTransactionableStoreOutputOperator.java | 1 + ...BatchTransactionableStoreOutputOperator.java | 1 + .../db/AbstractKeyValueStoreInputOperator.java | 1 + ...nsactionableKeyValueStoreOutputOperator.java | 1 + ...sThruTransactionableStoreOutputOperator.java | 1 + .../lib/db/AbstractStoreInputOperator.java | 1 + .../lib/db/AbstractStoreOutputOperator.java | 1 + ...tractTransactionableStoreOutputOperator.java | 1 + .../lib/db/TransactionableKeyValueStore.java | 1 + .../datatorrent/lib/db/cache/package-info.java | 20 +++++++++++++++++++ .../lib/db/jdbc/AbstractJdbcInputOperator.java | 1 + ...actJdbcNonTransactionableOutputOperator.java | 3 +-- ...stractJdbcTransactionableOutputOperator.java | 3 --- .../db/jdbc/JDBCLookupCacheBackedOperator.java | 1 + .../lib/db/jdbc/JdbcPOJOInputOperator.java | 4 +--- .../lib/db/jdbc/JdbcPOJOOutputOperator.java | 4 +--- .../com/datatorrent/lib/db/jdbc/JdbcStore.java | 3 --- .../lib/db/jdbc/JdbcTransactionalStore.java | 3 --- .../lib/dimensions/package-info.java | 20 +++++++++++++++++++ .../lib/fileaccess/package-info.java | 20 +++++++++++++++++++ .../datatorrent/lib/formatter/Formatter.java | 4 +--- .../lib/formatter/JsonFormatter.java | 3 +-- .../datatorrent/lib/formatter/XmlFormatter.java | 3 +-- .../lib/io/AbstractFTPInputOperator.java | 3 +-- .../AbstractHttpGetMultiValuedMapOperator.java | 1 + .../lib/io/AbstractHttpGetOperator.java | 1 + .../lib/io/AbstractHttpInputOperator.java | 1 + .../lib/io/AbstractHttpOperator.java | 1 + .../io/AbstractKeyValueStoreOutputOperator.java | 1 + .../lib/io/AbstractSocketInputOperator.java | 1 + .../datatorrent/lib/io/ApacheGenRandomLogs.java | 1 + .../CollectionMultiConsoleOutputOperator.java | 1 + .../lib/io/ConsoleOutputOperator.java | 1 + .../datatorrent/lib/io/HttpGetMapOperator.java | 1 + .../lib/io/HttpJsonChunksInputOperator.java | 1 + .../lib/io/HttpLinesInputOperator.java | 1 + .../lib/io/HttpPostOutputOperator.java | 1 + .../lib/io/MapMultiConsoleOutputOperator.java | 1 + .../lib/io/PubSubWebSocketAppDataQuery.java | 10 ++-------- .../lib/io/PubSubWebSocketAppDataResult.java | 3 --- .../lib/io/PubSubWebSocketInputOperator.java | 3 --- .../lib/io/PubSubWebSocketOutputOperator.java | 1 + .../lib/io/SimpleSinglePortInputOperator.java | 1 + .../datatorrent/lib/io/SmtpOutputOperator.java | 1 + .../lib/io/WebSocketInputOperator.java | 21 ++++++++++---------- .../lib/io/WebSocketOutputOperator.java | 1 + .../lib/io/WebSocketServerInputOperator.java | 1 + .../lib/io/WidgetOutputOperator.java | 1 + .../lib/io/block/AbstractBlockReader.java | 2 -- .../lib/io/block/AbstractFSBlockReader.java | 2 -- .../datatorrent/lib/io/block/BlockMetadata.java | 3 --- .../datatorrent/lib/io/block/FSSliceReader.java | 3 --- .../datatorrent/lib/io/block/ReaderContext.java | 2 -- .../lib/io/fs/AbstractFileInputOperator.java | 2 -- .../lib/io/fs/AbstractFileOutputOperator.java | 2 -- .../lib/io/fs/AbstractFileSplitter.java | 1 + .../lib/io/fs/AbstractReconciler.java | 4 +--- .../io/fs/AbstractSingleFileOutputOperator.java | 3 --- .../fs/AbstractThroughputFileInputOperator.java | 1 + .../io/fs/AbstractWindowFileOutputOperator.java | 1 + .../datatorrent/lib/io/fs/FileSplitterBase.java | 2 -- .../lib/io/fs/FileSplitterInput.java | 2 -- .../lib/io/fs/FilterStreamCodec.java | 3 --- .../lib/io/fs/FilterStreamContext.java | 3 --- .../lib/io/fs/FilterStreamProvider.java | 3 --- .../lib/io/fs/TailFsInputOperator.java | 1 + .../lib/io/jms/AbstractJMSInputOperator.java | 2 -- .../lib/io/jms/AbstractJMSOutputOperator.java | 1 + .../AbstractJMSSinglePortOutputOperator.java | 1 + .../io/jms/FSPsuedoTransactionableStore.java | 1 + .../com/datatorrent/lib/io/jms/JMSBase.java | 7 +++---- .../lib/io/jms/JMSBaseTransactionableStore.java | 1 + .../lib/io/jms/JMSMultiPortOutputOperator.java | 1 + .../lib/io/jms/JMSObjectInputOperator.java | 1 + .../lib/io/jms/JMSStringInputOperator.java | 1 + .../lib/io/jms/JMSTransactionableStore.java | 1 + .../com/datatorrent/lib/logs/package-info.java | 2 +- .../com/datatorrent/lib/math/package-info.java | 2 +- .../datatorrent/lib/metric/package-info.java | 3 --- .../lib/multiwindow/package-info.java | 2 +- .../datatorrent/lib/parser/package-info.java | 20 +++++++++++++++++++ .../lib/partitioner/package-info.java | 20 +++++++++++++++++++ .../datatorrent/lib/script/package-info.java | 2 +- .../lib/statistics/package-info.java | 20 +++++++++++++++++++ .../com/datatorrent/lib/stream/Counter.java | 3 --- .../com/datatorrent/lib/stream/DevNull.java | 3 --- .../datatorrent/lib/stream/package-info.java | 2 +- .../lib/streamquery/package-info.java | 2 +- .../datatorrent/lib/testbench/package-info.java | 2 +- .../com/datatorrent/lib/util/PojoUtils.java | 2 -- .../datatorrent/lib/util/WindowDataManager.java | 2 -- .../lib/util/comparator/SliceComparator.java | 2 -- .../com/datatorrent/lib/util/package-info.java | 7 ++++--- .../lib/xml/AbstractXmlDOMOperator.java | 1 + .../hadoop/io/file/tfile/CacheManager.java | 3 --- .../hadoop/io/file/tfile/package-info.java | 20 +++++++++++++++++++ pom.xml | 9 ++++----- 133 files changed, 585 insertions(+), 160 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/accumulo/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/accumulo/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/accumulo/package-info.java new file mode 100644 index 0000000..cbac406 --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/accumulo/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.accumulo; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/aerospike/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/aerospike/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/aerospike/package-info.java new file mode 100644 index 0000000..97e878c --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/aerospike/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.aerospike; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java index 2dd995b..d99c7b5 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/apachelog/package-info.java @@ -19,4 +19,5 @@ /** * Apache log application, operators, and utilities. */ [email protected] package com.datatorrent.contrib.apachelog; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/cassandra/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/cassandra/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/cassandra/package-info.java new file mode 100644 index 0000000..1baae5e --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/cassandra/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.cassandra; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/couchbase/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/couchbase/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/couchbase/package-info.java new file mode 100644 index 0000000..1a6d05b --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/couchbase/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.couchbase; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/couchdb/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/couchdb/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/couchdb/package-info.java new file mode 100644 index 0000000..be6ec34 --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/couchdb/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.couchdb; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/elasticsearch/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/elasticsearch/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/elasticsearch/package-info.java new file mode 100644 index 0000000..d89d53f --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/elasticsearch/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.elasticsearch; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java b/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java index 78a7c78..4b4bae3 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java +++ b/contrib/src/main/java/com/datatorrent/contrib/formatter/CsvFormatter.java @@ -33,7 +33,6 @@ import org.supercsv.exception.SuperCsvException; import org.supercsv.io.CsvBeanWriter; import org.supercsv.io.ICsvBeanWriter; import org.supercsv.prefs.CsvPreference; -import org.apache.hadoop.classification.InterfaceStability; import com.datatorrent.api.Context; import com.datatorrent.lib.formatter.Formatter; @@ -55,7 +54,7 @@ import com.datatorrent.netlet.util.DTThrowable; * @tags pojo csv formatter * @since 3.2.0 */ [email protected] [email protected] public class CsvFormatter extends Formatter<String> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java index 4ef8da9..41c15d1 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/hbase/package-info.java @@ -16,7 +16,8 @@ * specific language governing permissions and limitations * under the License. */ -/** - * HBase operators and utilities. - */ +/** + * HBase operators and utilities. + */ [email protected] package com.datatorrent.contrib.hbase; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/hive/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/hive/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/hive/package-info.java new file mode 100644 index 0000000..ad93d8f --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/hive/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.hive; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/jython/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/jython/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/jython/package-info.java new file mode 100644 index 0000000..08b3a3e --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/jython/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.jython; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java index 6cc91af..ea25951 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/kafka/package-info.java @@ -19,7 +19,4 @@ /** * Kafka operators and utilities. */ [email protected] package com.datatorrent.contrib.kafka; - -import org.apache.hadoop.classification.InterfaceStability; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/kinesis/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/kinesis/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/kinesis/package-info.java new file mode 100644 index 0000000..72a273c --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/kinesis/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.kinesis; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java index 6137e2a..599d342 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/memcache/package-info.java @@ -16,7 +16,8 @@ * specific language governing permissions and limitations * under the License. */ -/** - * Memcache operators and utilities. - */ +/** + * Memcache operators and utilities. + */ [email protected] package com.datatorrent.contrib.memcache; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java index 68f03ce..ab35817 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/memcache_whalin/package-info.java @@ -16,7 +16,8 @@ * specific language governing permissions and limitations * under the License. */ -/** - * Memcache operators and utilities using whalin library. - */ +/** + * Memcache operators and utilities using whalin library. + */ [email protected] package com.datatorrent.contrib.memcache_whalin; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/memsql/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/memsql/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/memsql/package-info.java new file mode 100644 index 0000000..a23b118 --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/memsql/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.memsql; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java index 6855353..05797ff 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/mongodb/package-info.java @@ -16,7 +16,8 @@ * specific language governing permissions and limitations * under the License. */ -/** - * MongoDB operators and utilities. - */ +/** + * MongoDB operators and utilities. + */ [email protected] package com.datatorrent.contrib.mongodb; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java index 5286aa1..0c94e16 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/mqtt/package-info.java @@ -19,4 +19,5 @@ /** * MQTT operators and utilities. */ [email protected] package com.datatorrent.contrib.mqtt; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java b/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java index ada368c..af1eebe 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java +++ b/contrib/src/main/java/com/datatorrent/contrib/parser/CsvParser.java @@ -35,9 +35,7 @@ import org.supercsv.cellprocessor.ParseLong; import org.supercsv.cellprocessor.ift.CellProcessor; import org.supercsv.io.CsvBeanReader; import org.supercsv.prefs.CsvPreference; -import org.apache.hadoop.classification.InterfaceStability; -import com.datatorrent.api.Context; import com.datatorrent.api.Context.OperatorContext; import com.datatorrent.lib.parser.Parser; import com.datatorrent.lib.util.ReusableStringReader; @@ -61,7 +59,6 @@ import com.datatorrent.netlet.util.DTThrowable; * @tags csv pojo parser * @since 3.2.0 */ [email protected] public class CsvParser extends Parser<String, String> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/parser/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/parser/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/parser/package-info.java new file mode 100644 index 0000000..cb54b65 --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/parser/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.parser; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/r/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/r/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/r/package-info.java new file mode 100644 index 0000000..4c0730c --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/r/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.r; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java index e201b51..4da2d04 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/rabbitmq/package-info.java @@ -16,7 +16,8 @@ * specific language governing permissions and limitations * under the License. */ -/** - * RabbitMQ operators and utilities. - */ +/** + * RabbitMQ operators and utilities. + */ [email protected] package com.datatorrent.contrib.rabbitmq; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java index 30a181e..d2f7a91 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/redis/package-info.java @@ -19,4 +19,5 @@ /** * Redis operators and utilities. */ [email protected] package com.datatorrent.contrib.redis; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java index bc252f1..b95c482 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/romesyndication/package-info.java @@ -16,7 +16,8 @@ * specific language governing permissions and limitations * under the License. */ -/** - * Rome operators and utilities. - */ +/** + * Rome operators and utilities. + */ [email protected] package com.datatorrent.contrib.romesyndication; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java b/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java index 8d01879..bfb9e83 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java +++ b/contrib/src/main/java/com/datatorrent/contrib/ruby/RubyOperator.java @@ -40,6 +40,7 @@ import com.datatorrent.lib.script.ScriptOperator; * @tags script, map, string * @since 1.0.4 */ [email protected] public class RubyOperator extends ScriptOperator { public enum Type http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/solr/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/solr/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/solr/package-info.java new file mode 100644 index 0000000..5ebbbf7 --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/solr/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.solr; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/splunk/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/splunk/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/splunk/package-info.java new file mode 100644 index 0000000..610ee3b --- /dev/null +++ b/contrib/src/main/java/com/datatorrent/contrib/splunk/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.contrib.splunk; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java index 762662d..469c4a1 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/sqlite/package-info.java @@ -16,7 +16,8 @@ * specific language governing permissions and limitations * under the License. */ -/** - * SQLite operators and utilities. - */ +/** + * SQLite operators and utilities. + */ [email protected] package com.datatorrent.contrib.sqlite; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java b/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java index b08daf5..1fa9b37 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java +++ b/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java @@ -50,6 +50,7 @@ import com.datatorrent.api.Operator.ActivationListener; * @tags input operator * @since 0.3.2 */ [email protected] public class TwitterSampleInput implements InputOperator, ActivationListener<OperatorContext>, StatusListener { /** http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java b/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java index dddd566..1ab0099 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java +++ b/contrib/src/main/java/com/datatorrent/contrib/zmq/package-info.java @@ -16,7 +16,8 @@ * specific language governing permissions and limitations * under the License. */ -/** - * ZeroMQ operators and utilities. - */ +/** + * ZeroMQ operators and utilities. + */ [email protected] package com.datatorrent.contrib.zmq; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/algo/package-info.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/algo/package-info.java b/library/src/main/java/com/datatorrent/lib/algo/package-info.java index 30a49c4..d368186 100644 --- a/library/src/main/java/com/datatorrent/lib/algo/package-info.java +++ b/library/src/main/java/com/datatorrent/lib/algo/package-info.java @@ -19,5 +19,5 @@ /** * Library of algorithmic operators */ - [email protected] package com.datatorrent.lib.algo; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/appdata/package-info.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/appdata/package-info.java b/library/src/main/java/com/datatorrent/lib/appdata/package-info.java new file mode 100644 index 0000000..3218464 --- /dev/null +++ b/library/src/main/java/com/datatorrent/lib/appdata/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.lib.appdata; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/codec/package-info.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/codec/package-info.java b/library/src/main/java/com/datatorrent/lib/codec/package-info.java index 08b2c56..ded8689 100644 --- a/library/src/main/java/com/datatorrent/lib/codec/package-info.java +++ b/library/src/main/java/com/datatorrent/lib/codec/package-info.java @@ -19,6 +19,6 @@ /** * Shared codec implementations. */ - [email protected] package com.datatorrent.lib.codec; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/converter/package-info.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/converter/package-info.java b/library/src/main/java/com/datatorrent/lib/converter/package-info.java new file mode 100644 index 0000000..77429e9 --- /dev/null +++ b/library/src/main/java/com/datatorrent/lib/converter/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.lib.converter; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/counters/package-info.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/counters/package-info.java b/library/src/main/java/com/datatorrent/lib/counters/package-info.java index 6d8286f..c8ea286 100644 --- a/library/src/main/java/com/datatorrent/lib/counters/package-info.java +++ b/library/src/main/java/com/datatorrent/lib/counters/package-info.java @@ -19,4 +19,5 @@ /** * Basic counters and aggregates implementations. */ -package com.datatorrent.lib.counters; \ No newline at end of file [email protected] +package com.datatorrent.lib.counters; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java index f485dd8..ba89f7b 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableKeyValueStoreOutputOperator.java @@ -32,6 +32,7 @@ package com.datatorrent.lib.db; * @param <S> The store type. * @since 0.9.3 */ [email protected] public abstract class AbstractAggregateTransactionableKeyValueStoreOutputOperator<T, S extends TransactionableKeyValueStore> extends AbstractAggregateTransactionableStoreOutputOperator<T, S> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java index 3ce9df5..f17dfb0 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractAggregateTransactionableStoreOutputOperator.java @@ -32,6 +32,7 @@ package com.datatorrent.lib.db; * @param <S> The store type. * @since 0.9.3 */ [email protected] public abstract class AbstractAggregateTransactionableStoreOutputOperator<T, S extends TransactionableStore> extends AbstractTransactionableStoreOutputOperator<T, S> { @Override http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java index 4714921..771e679 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractBatchTransactionableStoreOutputOperator.java @@ -34,6 +34,7 @@ import com.google.common.collect.Lists; * @param <S> The store type. * @since 1.0.2 */ [email protected] public abstract class AbstractBatchTransactionableStoreOutputOperator<T, S extends TransactionableStore> extends AbstractAggregateTransactionableStoreOutputOperator<T, S> { private Collection<T> tuples; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java index 10407e9..9b6ddc2 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractKeyValueStoreInputOperator.java @@ -34,6 +34,7 @@ import java.util.*; * @param <S> The store type. * @since 0.9.3 */ [email protected] public abstract class AbstractKeyValueStoreInputOperator<T, S extends KeyValueStore> extends AbstractStoreInputOperator<T, S> { protected List<Object> keys = new ArrayList<Object>(); http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java index 92627d6..f199986 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableKeyValueStoreOutputOperator.java @@ -34,6 +34,7 @@ package com.datatorrent.lib.db; * @param <S> The store type * @since 0.9.3 */ [email protected] public abstract class AbstractPassThruTransactionableKeyValueStoreOutputOperator<T, S extends TransactionableKeyValueStore> extends AbstractPassThruTransactionableStoreOutputOperator<T, S> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java index 025a4c3..55c8617 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractPassThruTransactionableStoreOutputOperator.java @@ -34,6 +34,7 @@ package com.datatorrent.lib.db; * @param <S> The store type * @since 0.9.3 */ [email protected] public abstract class AbstractPassThruTransactionableStoreOutputOperator<T, S extends TransactionableStore> extends AbstractTransactionableStoreOutputOperator<T, S> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java index 21e1707..a6eb780 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractStoreInputOperator.java @@ -35,6 +35,7 @@ import com.datatorrent.api.InputOperator; * @param <S> The store type * @since 0.9.3 */ [email protected] public abstract class AbstractStoreInputOperator<T, S extends Connectable> implements InputOperator { /** http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java index 4f864b6..aff5b3e 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractStoreOutputOperator.java @@ -38,6 +38,7 @@ import com.datatorrent.api.annotation.InputPortFieldAnnotation; * @param <S> The store type * @since 0.9.3 */ [email protected] public abstract class AbstractStoreOutputOperator<T, S extends Connectable> extends BaseOperator { protected S store; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java index 645855a..61682c2 100644 --- a/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/AbstractTransactionableStoreOutputOperator.java @@ -43,6 +43,7 @@ import com.datatorrent.api.annotation.InputPortFieldAnnotation; * @param <S> The store type * @since 0.9.3 */ [email protected] public abstract class AbstractTransactionableStoreOutputOperator<T, S extends TransactionableStore> extends BaseOperator { protected S store; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java b/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java index 6264154..3263b87 100644 --- a/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java +++ b/library/src/main/java/com/datatorrent/lib/db/TransactionableKeyValueStore.java @@ -23,6 +23,7 @@ package com.datatorrent.lib.db; * * @since 0.9.3 */ [email protected] public interface TransactionableKeyValueStore extends TransactionableStore, KeyValueStore { } http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/cache/package-info.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/cache/package-info.java b/library/src/main/java/com/datatorrent/lib/db/cache/package-info.java new file mode 100644 index 0000000..efdfef3 --- /dev/null +++ b/library/src/main/java/com/datatorrent/lib/db/cache/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.lib.db.cache; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java index c473ce3..e63610f 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java @@ -45,6 +45,7 @@ import com.datatorrent.lib.db.AbstractStoreInputOperator; * @param <T> The tuple type * @since 0.9.4 */ [email protected] public abstract class AbstractJdbcInputOperator<T> extends AbstractStoreInputOperator<T, JdbcStore> { private static final Logger logger = LoggerFactory.getLogger(AbstractJdbcInputOperator.class); http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java index d776965..3de0376 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcNonTransactionableOutputOperator.java @@ -21,8 +21,6 @@ package com.datatorrent.lib.db.jdbc; import java.sql.PreparedStatement; import java.sql.SQLException; - - import com.datatorrent.api.Context; import com.datatorrent.lib.db.AbstractStoreOutputOperator; @@ -37,6 +35,7 @@ import com.datatorrent.lib.db.AbstractStoreOutputOperator; * @param <T> The kind of tuples that are being processed * @since 1.0.4 */ [email protected] public abstract class AbstractJdbcNonTransactionableOutputOperator<T, S extends JdbcStore> extends AbstractStoreOutputOperator<T, S> { protected transient PreparedStatement updateCommand; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java index d59e231..77b76c1 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcTransactionableOutputOperator.java @@ -28,8 +28,6 @@ import javax.validation.constraints.NotNull; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.hadoop.classification.InterfaceStability; - import com.google.common.collect.Lists; import com.datatorrent.api.Context; @@ -57,7 +55,6 @@ import com.datatorrent.lib.db.AbstractPassThruTransactionableStoreOutputOperator * @param <T> type of tuple * @since 0.9.4 */ [email protected] public abstract class AbstractJdbcTransactionableOutputOperator<T> extends AbstractPassThruTransactionableStoreOutputOperator<T, JdbcTransactionalStore> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java index 7ca2ae1..b6a66a3 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JDBCLookupCacheBackedOperator.java @@ -44,6 +44,7 @@ import com.datatorrent.lib.db.cache.AbstractDBLookupCacheBackedOperator; * @param <T> type of input tuples </T> * @since 0.9.1 */ [email protected] public abstract class JDBCLookupCacheBackedOperator<T> extends AbstractDBLookupCacheBackedOperator<T, JdbcStore> { @NotNull http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java index 3568b62..8aea9b6 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOInputOperator.java @@ -36,8 +36,6 @@ import javax.validation.constraints.NotNull; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.hadoop.classification.InterfaceStability; - import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Maps; @@ -66,7 +64,7 @@ import com.datatorrent.lib.util.PojoUtils; * @tags database, sql, pojo, jdbc * @since 2.1.0 */ [email protected] [email protected] public class JdbcPOJOInputOperator extends AbstractJdbcInputOperator<Object> implements Operator.ActivationListener<Context.OperatorContext> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java index ffb4160..a7dcb2a 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOOutputOperator.java @@ -35,8 +35,6 @@ import javax.validation.constraints.NotNull; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.hadoop.classification.InterfaceStability.Evolving; - import com.google.common.collect.Lists; import com.datatorrent.api.Context; @@ -64,7 +62,7 @@ import com.datatorrent.lib.util.PojoUtils.GetterShort; * @tags database, sql, pojo, jdbc * @since 2.1.0 */ -@Evolving [email protected] public class JdbcPOJOOutputOperator extends AbstractJdbcTransactionableOutputOperator<Object> implements Operator.ActivationListener<OperatorContext> { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java index 6af2b50..d9901aa 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcStore.java @@ -28,8 +28,6 @@ import javax.validation.constraints.NotNull; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.hadoop.classification.InterfaceStability; - import com.google.common.base.CharMatcher; import com.google.common.base.Splitter; import com.google.common.collect.Iterables; @@ -42,7 +40,6 @@ import com.datatorrent.netlet.util.DTThrowable; * * @since 0.9.4 */ [email protected] public class JdbcStore implements Connectable { protected static final Logger logger = LoggerFactory.getLogger(JdbcStore.class); http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java index 9d9266d..9bc18b0 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcTransactionalStore.java @@ -27,8 +27,6 @@ import javax.validation.constraints.NotNull; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.hadoop.classification.InterfaceStability; - import com.datatorrent.lib.db.TransactionableStore; /** @@ -36,7 +34,6 @@ import com.datatorrent.lib.db.TransactionableStore; * * @since 0.9.4 */ [email protected] public class JdbcTransactionalStore extends JdbcStore implements TransactionableStore { private static final transient Logger LOG = LoggerFactory.getLogger(JdbcTransactionalStore.class); http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/dimensions/package-info.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/dimensions/package-info.java b/library/src/main/java/com/datatorrent/lib/dimensions/package-info.java new file mode 100644 index 0000000..4988df7 --- /dev/null +++ b/library/src/main/java/com/datatorrent/lib/dimensions/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.lib.dimensions; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/fileaccess/package-info.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/fileaccess/package-info.java b/library/src/main/java/com/datatorrent/lib/fileaccess/package-info.java new file mode 100644 index 0000000..8002459 --- /dev/null +++ b/library/src/main/java/com/datatorrent/lib/fileaccess/package-info.java @@ -0,0 +1,20 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ [email protected] +package com.datatorrent.lib.fileaccess; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java b/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java index b7101fb..7d0018e 100644 --- a/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java +++ b/library/src/main/java/com/datatorrent/lib/formatter/Formatter.java @@ -18,8 +18,6 @@ */ package com.datatorrent.lib.formatter; -import org.apache.hadoop.classification.InterfaceStability; - import com.datatorrent.api.Context; import com.datatorrent.api.Context.PortContext; import com.datatorrent.api.DefaultInputPort; @@ -45,7 +43,7 @@ import com.datatorrent.lib.converter.Converter; * @param <INPUT> * @since 3.2.0 */ [email protected] [email protected] public abstract class Formatter<OUTPUT> extends BaseOperator implements Converter<Object, OUTPUT> { protected transient Class<?> clazz; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java b/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java index 4ed24b4..fa17fda 100644 --- a/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java +++ b/library/src/main/java/com/datatorrent/lib/formatter/JsonFormatter.java @@ -28,7 +28,6 @@ import org.codehaus.jackson.map.ObjectWriter; import org.codehaus.jackson.map.SerializationConfig; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.hadoop.classification.InterfaceStability; import com.datatorrent.api.Context.OperatorContext; import com.datatorrent.netlet.util.DTThrowable; @@ -43,7 +42,7 @@ import com.datatorrent.netlet.util.DTThrowable; * @tags pojo json formatter * @since 3.2.0 */ [email protected] [email protected] public class JsonFormatter extends Formatter<String> { private transient ObjectWriter writer; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java b/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java index 9ad2612..21a7b6a 100644 --- a/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java +++ b/library/src/main/java/com/datatorrent/lib/formatter/XmlFormatter.java @@ -28,7 +28,6 @@ import javax.xml.namespace.QName; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.hadoop.classification.InterfaceStability; import com.datatorrent.api.Context.OperatorContext; import com.datatorrent.netlet.util.DTThrowable; @@ -39,7 +38,7 @@ import com.datatorrent.netlet.util.DTThrowable; * @tags xml pojo formatter * @since 3.2.0 */ [email protected] [email protected] public class XmlFormatter extends Formatter<String> { protected String alias; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java index c9f0604..1401100 100644 --- a/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/AbstractFTPInputOperator.java @@ -31,7 +31,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.apache.commons.net.ftp.FTP; -import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.ftp.FTPFileSystem; @@ -57,7 +56,7 @@ import com.datatorrent.lib.io.fs.AbstractFileInputOperator; * * @since 2.0.0 */ [email protected] [email protected] public abstract class AbstractFTPInputOperator<T> extends AbstractFileInputOperator<T> { @NotNull http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java index 7a70deb..e3675a8 100644 --- a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetMultiValuedMapOperator.java @@ -35,6 +35,7 @@ import com.sun.jersey.api.client.WebResource; * @param <OUTPUT> * @since 1.0.2 */ [email protected] public abstract class AbstractHttpGetMultiValuedMapOperator<INPUT, OUTPUT> extends AbstractHttpGetOperator<INPUT, OUTPUT> { @Override http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java index e5ed969..fe9a50f 100644 --- a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpGetOperator.java @@ -40,6 +40,7 @@ import com.datatorrent.api.annotation.OutputPortFieldAnnotation; * @param <OUTPUT> tuple type of output port * @since 1.0.2 */ [email protected] public abstract class AbstractHttpGetOperator<INPUT, OUTPUT> extends AbstractHttpOperator<INPUT> { /** http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java index e07013e..d7bb503 100644 --- a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpInputOperator.java @@ -44,6 +44,7 @@ import com.sun.jersey.api.client.WebResource; * * @since 0.3.2 */ [email protected] public abstract class AbstractHttpInputOperator<T> extends SimpleSinglePortInputOperator<T> implements Runnable { /** http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java index 13dc01f..d5b8de6 100644 --- a/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/AbstractHttpOperator.java @@ -41,6 +41,7 @@ import com.datatorrent.api.DefaultInputPort; * @param <T> * @since 1.0.2 */ [email protected] public abstract class AbstractHttpOperator<T> extends BaseOperator { @NotNull http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java index d2b011f..835f2a6 100644 --- a/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/AbstractKeyValueStoreOutputOperator.java @@ -42,6 +42,7 @@ import com.datatorrent.lib.util.KeyValPair; * * @since 0.3.2 */ [email protected] public abstract class AbstractKeyValueStoreOutputOperator<K, V> extends BaseOperator { private static final Logger LOG = LoggerFactory.getLogger(AbstractKeyValueStoreOutputOperator.class); http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java index 571580f..4f1e3df 100644 --- a/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/AbstractSocketInputOperator.java @@ -48,6 +48,7 @@ import com.datatorrent.api.Operator.ActivationListener; * @param <T> * @since 0.9.5 */ [email protected] public abstract class AbstractSocketInputOperator<T> implements InputOperator, ActivationListener<OperatorContext> { /* The host to which to connect */ http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java b/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java index 8c1be97..d1afc60 100644 --- a/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java +++ b/library/src/main/java/com/datatorrent/lib/io/ApacheGenRandomLogs.java @@ -56,6 +56,7 @@ import com.datatorrent.api.Context.OperatorContext; * * @since 0.3.2 */ [email protected] public class ApacheGenRandomLogs extends BaseOperator implements InputOperator { /** http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java index 3b2ff8e..1c142a4 100644 --- a/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/CollectionMultiConsoleOutputOperator.java @@ -42,6 +42,7 @@ import com.datatorrent.api.DefaultInputPort; * * @since 0.3.4 */ [email protected] public class CollectionMultiConsoleOutputOperator<E> extends BaseOperator { private boolean debug = false; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java index 93c99cc..5e72d3d 100644 --- a/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/ConsoleOutputOperator.java @@ -37,6 +37,7 @@ import org.slf4j.LoggerFactory; * * @since 0.3.2 */ [email protected] @Stateless public class ConsoleOutputOperator extends BaseOperator { http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java b/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java index 9e846b2..07e28b8 100644 --- a/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/HttpGetMapOperator.java @@ -38,6 +38,7 @@ import com.sun.jersey.api.client.WebResource; * @param <V> Type of value in input map tuple * @since 1.0.2 */ [email protected] public class HttpGetMapOperator<K, V> extends AbstractHttpGetOperator<Map<K, V>, String> { @Override http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java index 14acfe3..ea1fc8d 100644 --- a/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/HttpJsonChunksInputOperator.java @@ -47,6 +47,7 @@ import org.slf4j.LoggerFactory; * * @since 0.9.4 */ [email protected] public class HttpJsonChunksInputOperator extends AbstractHttpInputOperator<Map<String, String>> { private static final Logger LOG = LoggerFactory.getLogger(HttpJsonChunksInputOperator.class); http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java b/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java index 187a38c..a483df1 100644 --- a/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/HttpLinesInputOperator.java @@ -33,6 +33,7 @@ import java.io.InputStreamReader; * * @since 0.9.4 */ [email protected] public class HttpLinesInputOperator extends AbstractHttpInputOperator<String> { @Override http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java index a613898..a69761c 100644 --- a/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/HttpPostOutputOperator.java @@ -41,6 +41,7 @@ import com.datatorrent.api.Context.OperatorContext; * @param <T> * @since 0.3.2 */ [email protected] public class HttpPostOutputOperator<T> extends AbstractHttpOperator<T> { protected transient WebResource resource; http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d570b8d6/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java b/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java index b4ba09a..c461163 100644 --- a/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/io/MapMultiConsoleOutputOperator.java @@ -41,6 +41,7 @@ import com.datatorrent.api.DefaultInputPort; * * @since 0.3.4 */ [email protected] public class MapMultiConsoleOutputOperator<K, V> extends BaseOperator { private boolean debug = false;
