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

import com.malhartech.dag.Sink;
import com.malhartech.dag.Stream;
import com.malhartech.dag.StreamConfiguration;
import com.malhartech.dag.StreamContext;
import com.malhartech.dag.Tuple;
import kafka.javaapi.producer.Producer;

/**
 *
 * @author Chetan Narsude <chetan@malhar-inc.com>
 */
public class KafkaOutputStream
  implements Stream, Sink
{
  @Override
  public void setup(StreamConfiguration config)
  {
    Producer producer;

    throw new UnsupportedOperationException("Not supported yet.");
  }

  @Override
  public void setContext(StreamContext context)
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  @Override
  public void teardown()
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  @Override
  public void doSomething(Tuple t)
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  @Override
  public StreamContext getContext()
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  public boolean hasFinished()
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  public void activate()
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }
}

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

import com.malhartech.api.Sink;
import com.malhartech.dag.Stream;
import com.malhartech.dag.StreamConfiguration;
import com.malhartech.dag.StreamContext;
import com.malhartech.dag.Tuple;
import kafka.javaapi.producer.Producer;

/**
 *
 * @author Chetan Narsude <chetan@malhar-inc.com>
 */
public class KafkaOutputStream
  implements Stream, Sink
{
  @Override
  public void setup(StreamConfiguration config)
  {
    Producer producer;

    throw new UnsupportedOperationException("Not supported yet.");
  }

  @Override
  public void setContext(StreamContext context)
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  @Override
  public void teardown()
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  @Override
  public void doSomething(Tuple t)
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  @Override
  public StreamContext getContext()
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  public boolean hasFinished()
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }

  public void activate()
  {
    throw new UnsupportedOperationException("Not supported yet.");
  }
}

Integrate new packages. The code does not compile.
Integrate new packages. The code does not compile.
