/*
 *  Copyright (c) 2012 Malhar, Inc.
 *  All Rights Reserved.
 */
package com.malhartech.dag;

/**
 *
 * @author Chetan Narsude <chetan@malhar-inc.com>
 */
public interface Stream extends DAGPart<StreamConfiguration, StreamContext>
{
  @Override
  public void setup(StreamConfiguration config);

  public void setContext(StreamContext context);

  public StreamContext getContext();

  public void activate();
  
  @Override
  public void teardown();
}

@@ -229,16 +229,178 @@
 text%3E%0A%7B%0A
+  public static final StreamContext DISCONNECTED_STREAM_CONTEXT = new StreamContext(null, null)%0A  %7B%0A    @Override%0A    public void sink(Tuple t)%0A    %7B%0A    %7D%0A  %7D;%0A%0A
   @Overr
@@ -567,18 +567,16 @@
 vate();%0A
-  
 %0A  @Over

add definition of context which has shunted sink.