in scalafix/output-0_12/src/main/scala/fix/v0_12_0/FixPubsubSpecializations.scala [14:111]
override def get(field: Int) = ???
override def put(field: Int, value: Any) = ???
}
def contextPubsubSubscription(sc: ScioContext): Unit =
sc.read(PubsubIO.string("theName"))(PubsubIO.ReadParam(PubsubIO.Subscription))
def contextPubsubTopic(sc: ScioContext): Unit =
sc.read(PubsubIO.string("theName"))(PubsubIO.ReadParam(PubsubIO.Topic))
def contextPubsubSubscriptionWithAtt(sc: ScioContext): Unit =
sc.read(PubsubIO.withAttributes[String]("theName"))(PubsubIO.ReadParam(PubsubIO.Subscription))
def contextPubsubTopicWithAtt(sc: ScioContext): Unit =
sc.read(PubsubIO.withAttributes[String]("theName"))(PubsubIO.ReadParam(PubsubIO.Topic))
def contextPubsubSubscriptionSpecifiRecord(sc: ScioContext): Unit =
sc.read(PubsubIO.avro[SpecificRecordDummy]("theName"))(PubsubIO.ReadParam(PubsubIO.Subscription))
def contextPubsubTopicSpecifiRecord(sc: ScioContext): Unit =
sc.read(PubsubIO.avro[SpecificRecordDummy]("theName"))(PubsubIO.ReadParam(PubsubIO.Topic))
def contextPubsubSubscriptionWithAttSpecifiRecord(sc: ScioContext): Unit =
sc.read(PubsubIO.withAttributes[SpecificRecordDummy]("theName"))(PubsubIO.ReadParam(PubsubIO.Subscription))
def contextPubsubTopicWithAttSpecifiRecord(sc: ScioContext): Unit =
sc.read(PubsubIO.withAttributes[SpecificRecordDummy]("theName"))(PubsubIO.ReadParam(PubsubIO.Topic))
def pubsubApplySpecificRecord(): Unit =
PubsubIO.avro[SpecificRecordDummy]("theName")
def pubsubApplySpecificRecordWithParams(): Unit =
PubsubIO.avro[SpecificRecordDummy]("theName", "idAtt", "timestampAtt")
def pubsubApplySpecificRecordWithNamedParams(): Unit =
PubsubIO.avro[SpecificRecordDummy]("theName", timestampAttribute = "idAtt", idAttribute = "timestampAtt")
def pubsubApplyProto(): Unit =
PubsubIO.proto[MessageDummy]("theName")
def pubsubApplyPubsub(): Unit =
PubsubIO.pubsub[PubSubMessageDummy]("theName")
def pubsubApplyString(): Unit =
PubsubIO.string("theName")
def pubsubApplyStringWithParams(): Unit =
PubsubIO.string("theName", "idAtt", "timestampAtt")
def pubsubApplyStringWithNamedParams(): Unit =
PubsubIO.string("theName", timestampAttribute = "idAtt", idAttribute = "timestampAtt")
def readAvro(): Unit =
PubsubIO.avro[SpecificRecordDummy]("theName")
def readAvroAllParams(): Unit =
PubsubIO.avro[SpecificRecordDummy]("theName", "idAtt", "timestampAtt")
def readAvroNamedParams(): Unit =
PubsubIO.avro[SpecificRecordDummy](name = "theName", timestampAttribute = "idAtt", idAttribute = "timestampAtt")
def readProto(): Unit =
PubsubIO.proto[MessageDummy]("theName")
def readProtoAllParams(): Unit =
PubsubIO.proto[MessageDummy]("theName", "idAtt", "timestampAtt")
def readProtoNamedParams(): Unit =
PubsubIO.proto[MessageDummy](name = "theName", timestampAttribute = "idAtt", idAttribute = "timestampAtt")
def readPubsub(): Unit =
PubsubIO.pubsub[PubSubMessageDummy]("theName")
def readPubsubAllParams(): Unit =
PubsubIO.pubsub[PubSubMessageDummy]("theName", "idAtt", "timestampAtt")
def readPubsubNamedParams(): Unit =
PubsubIO.pubsub[PubSubMessageDummy](name = "theName", timestampAttribute = "idAtt", idAttribute = "timestampAtt")
def readCoder(): Unit =
PubsubIO.coder[String]("theName")
def readCoderAllParams(): Unit =
PubsubIO.coder[String]("theName", "idAtt", "timestampAtt")
def readCoderNamedParams(): Unit =
PubsubIO.coder[String](name = "theName", timestampAttribute = "idAtt", idAttribute = "timestampAtt")
def readString(): Unit =
PubsubIO.string("theName")
def readStringAllParams(): Unit =
PubsubIO.string("theName", "idAtt", "timestampAtt")
def readStringNamedParams(): Unit =
PubsubIO.string(name = "theName", timestampAttribute = "idAtt", idAttribute = "timestampAtt")
def writePubSub(scoll: SCollection[String]): Unit = {