com.twitter.tormenta

ScalaInterop

object ScalaInterop extends

Source
ScalaInterop.java
Visibility
  1. Public
  2. All

Value Members

  1. def makeDRPC(function: String): DRPCSpout

  2. def newDRPCStream(top: TridentTopology, streamName: String): Stream