Class InstanceStreamToBatchMaker

All Implemented Interfaces:
ImageObserver, MenuContainer, Serializable, EventListener, Accessible, BeanCommon, DataSource, EventConstraints, InstanceListener, Visible

@KFStep(category="Flow", toolTipText="Converts an incoming instance stream into a data set batch") public class InstanceStreamToBatchMaker extends JPanel implements BeanCommon, Visible, InstanceListener, EventConstraints, DataSource
Bean that converts an instance stream into a (batch) data set. Useful in conjunction with the Reservoir sampling filter.
Version:
$Revision: 10220 $
Author:
Mark Hall (mhall{[at]}pentaho{[dot]}com)
See Also:
  • Constructor Details

    • InstanceStreamToBatchMaker

      public InstanceStreamToBatchMaker()
  • Method Details

    • acceptInstance

      public void acceptInstance(InstanceEvent e)
      Accept an instance to add to the batch.
      Specified by:
      acceptInstance in interface InstanceListener
      Parameters:
      e - an InstanceEvent value
    • connectionAllowed

      public boolean connectionAllowed(EventSetDescriptor esd)
      Returns true if, at this time, the object will accept a connection according to the supplied EventSetDescriptor
      Specified by:
      connectionAllowed in interface BeanCommon
      Parameters:
      esd - the EventSetDescriptor
      Returns:
      true if the object will accept a connection
    • connectionAllowed

      public boolean connectionAllowed(String eventName)
      Returns true if, at this time, the object will accept a connection with respect to the named event
      Specified by:
      connectionAllowed in interface BeanCommon
      Parameters:
      eventName - the event
      Returns:
      true if the object will accept a connection
    • connectionNotification

      public void connectionNotification(String eventName, Object source)
      Notify this object that it has been registered as a listener with a source with respect to the named event
      Specified by:
      connectionNotification in interface BeanCommon
      Parameters:
      eventName - the event
      source - the source with which this object has been registered as a listener
    • disconnectionNotification

      public void disconnectionNotification(String eventName, Object source)
      Notify this object that it has been deregistered as a listener with a source with respect to the supplied event name
      Specified by:
      disconnectionNotification in interface BeanCommon
      Parameters:
      eventName - the event
      source - the source with which this object has been registered as a listener
    • eventGeneratable

      public boolean eventGeneratable(String eventName)
      Returns true if, at the current time, the named event could be generated.
      Specified by:
      eventGeneratable in interface EventConstraints
      Parameters:
      eventName - the name of the event in question
      Returns:
      true if the named event could be generated
    • getCustomName

      public String getCustomName()
      Get the custom (descriptive) name for this bean (if one has been set)
      Specified by:
      getCustomName in interface BeanCommon
      Returns:
      the custom name (or the default name)
    • setCustomName

      public void setCustomName(String name)
      Set a custom (descriptive) name for this bean
      Specified by:
      setCustomName in interface BeanCommon
      Parameters:
      name - the name to use
    • setLog

      public void setLog(Logger logger)
      Set a logger
      Specified by:
      setLog in interface BeanCommon
      Parameters:
      logger - a Logger value
    • isBusy

      public boolean isBusy()
      Returns true if. at this time, the bean is busy with some (i.e. perhaps a worker thread is performing some calculation).
      Specified by:
      isBusy in interface BeanCommon
      Returns:
      true if the bean is busy.
    • stop

      public void stop()
      Stop any action (if possible).
      Specified by:
      stop in interface BeanCommon
    • getVisual

      public BeanVisual getVisual()
      Gets the visual appearance of this wrapper bean
      Specified by:
      getVisual in interface Visible
      Returns:
      a BeanVisual value
    • setVisual

      public void setVisual(BeanVisual newVisual)
      Sets the visual appearance of this wrapper bean
      Specified by:
      setVisual in interface Visible
      Parameters:
      newVisual - a BeanVisual value
    • useDefaultVisual

      public void useDefaultVisual()
      Use the default visual appearance for this bean
      Specified by:
      useDefaultVisual in interface Visible
    • addDataSourceListener

      public void addDataSourceListener(DataSourceListener tsl)
      Description copied from interface: DataSource
      Add a data source listener
      Specified by:
      addDataSourceListener in interface DataSource
      Parameters:
      tsl - a DataSourceListener value
    • removeDataSourceListener

      public void removeDataSourceListener(DataSourceListener tsl)
      Description copied from interface: DataSource
      Remove a data source listener
      Specified by:
      removeDataSourceListener in interface DataSource
      Parameters:
      tsl - a DataSourceListener value
    • addInstanceListener

      public void addInstanceListener(InstanceListener il)
      Description copied from interface: DataSource
      Add an instance listener
      Specified by:
      addInstanceListener in interface DataSource
      Parameters:
      il - an InstanceListener value
    • removeInstanceListener

      public void removeInstanceListener(InstanceListener il)
      Description copied from interface: DataSource
      Remove an instance listener
      Specified by:
      removeInstanceListener in interface DataSource
      Parameters:
      il - an InstanceListener value