Mailing-List: contact dev-help@streams.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@streams.incubator.apache.org
Content-Type: multipart/alternative;
 boundary="===============6617807599836322746=="
MIME-Version: 1.0
Subject: Review Request 18369: Issue STREAMS-26 in JIRA
From: "Ryan Ebanks" <ryanebanks@gmail.com>
To: "streams" <dev@streams.incubator.apache.org>,
 "Ryan Ebanks" <ryanebanks@gmail.com>
Date: Fri, 21 Feb 2014 20:05:03 -0000
Message-ID: <20140221200503.29785.29263@reviews.apache.org>
Auto-Submitted: auto-generated
Sender: "Ryan Ebanks" <noreply@reviews.apache.org>
Reply-To: "Ryan Ebanks" <ryanebanks@gmail.com>

--===============6617807599836322746==
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit


-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/18369/
-----------------------------------------------------------

Review request for streams.


Repository: streams


Description
-------

I made changes to simplify the interfaces for StreamsPersistWriter, StreamsProcessor, and StreamsProvider.  The reasons for the changes was to create a simple framework for running an activity stream in a single JVM, and to create a class that allowed a user to easily declare, and run their stream in a few lines of of code.  The interfaces have only slightly changed, mainly its the removal of certain methods.  The new changes, I believe this will allow for easy mapping of activity streams to other projects frame work, such as Storm, Hadoop, etc.  The builder interface used for declare and launching the stream will be easily extended to Storm.  When the patch gets approved I will work on implementing that.


Diffs
-----

  trunk/streams-core/pom.xml 1570675 
  trunk/streams-core/src/main/java/org/apache/streams/core/StreamsDatum.java 1570675 
  trunk/streams-core/src/main/java/org/apache/streams/core/StreamsOperation.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/StreamsPersistReader.java 1570675 
  trunk/streams-core/src/main/java/org/apache/streams/core/StreamsPersistWriter.java 1570675 
  trunk/streams-core/src/main/java/org/apache/streams/core/StreamsProcessor.java 1570675 
  trunk/streams-core/src/main/java/org/apache/streams/core/StreamsProvider.java 1570675 
  trunk/streams-core/src/main/java/org/apache/streams/core/builders/InvalidStreamException.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/builders/LocalStreamBuilder.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/builders/StreamBuilder.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/builders/StreamComponent.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/tasks/BaseStreamsTask.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/tasks/StreamsMergeTask.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/tasks/StreamsPersistWriterTask.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/tasks/StreamsProcessorTask.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/tasks/StreamsProviderTask.java PRE-CREATION 
  trunk/streams-core/src/main/java/org/apache/streams/core/tasks/StreamsTask.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/builders/LocalStreamBuilderTest.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/builders/ToyLocalBuilderExample.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/tasks/BasicTasksTest.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/test/processors/DoNothingProcessor.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/test/processors/PassthroughDatumCounterProcessor.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/test/providers/NumericMessageProvider.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/test/writer/DatumCounterWriter.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/test/writer/DoNothingWriter.java PRE-CREATION 
  trunk/streams-core/src/test/java/org/apache/streams/core/test/writer/SystemOutWriter.java PRE-CREATION 
  trunk/streams-util/src/main/java/org/apache/streams/util/SerializationUtil.java PRE-CREATION 

Diff: https://reviews.apache.org/r/18369/diff/


Testing
-------

There are units for the new functionality and classes.  I admit they are a little 'hacky'.


Thanks,

Ryan Ebanks


--===============6617807599836322746==--