Pinned Loading

1. An Airflow EMR Step Sensor that resu... An Airflow EMR Step Sensor that resubmits the step to the cluster for the retry amount of times.

   1

   class EmrStepSensorWithRetry(EmrBaseSensor):

   2

     """

   3

     Asks for the state of the step until it reaches a terminal state.

   4

     If it fails the sensor errors, if there is retries set it resubmits the step until 

   5

     it has failed the set amount of retry times at which point it will fail the task.

2. griffin griffin Public

   Forked from apache/griffin

   Mirror of Apache griffin

   Java

3. spark spark Public

   Forked from apache/spark

   Apache Spark

   Scala

4. spark-confluent-avro-poc spark-confluent-avro-poc Public

   A repo to hold the work done for a spark and confluent avro/schema registry integration POC

   Scala 1

5. apache/hudi apache/hudi Public

   Upserts, Deletes And Incremental Processing on Big Data.

   Java 5.5k 2.4k

6. AbsaOSS/ABRiS AbsaOSS/ABRiS Public

   Avro SerDe for Apache Spark structured APIs.

   Scala 232 76