skritch

import inspect
import re
from typing import Callable, Union, Optional
import types
from kedro.pipeline import Pipeline, node
from kedro.pipeline.node import Node


CAMEL_TO_SNAKE_RE = re.compile(r'(?<!^)(?=[A-Z])')

skritch

import scala.collection.JavaConverters._

import com.amazonaws.auth.DefaultAWSCredentialsProviderChain
import com.amazonaws.services.s3.model.{ListObjectsV2Request, ListObjectsV2Result}
import com.amazonaws.services.s3.{AmazonS3, AmazonS3ClientBuilder}
import org.apache.flink.api.common.serialization.SimpleStringEncoder
import org.apache.flink.api.scala._
import org.apache.flink.core.fs.Path
import org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink
import org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.BasePathBucketAssigner

skritch

import scala.collection.JavaConverters._
import scala.reflect.ClassTag
import scala.util.{Failure, Success, Try}

import org.apache.avro.generic.{GenericData, GenericRecord}
import org.apache.avro.{SchemaBuilder, Schema => AvroSchema}
import org.apache.flink.api.common.functions.RichMapFunction
import org.apache.flink.api.common.typeinfo.{TypeInformation, Types => JTypes}
import org.apache.flink.api.java.operators.DataSink

skritch

Keybase proof

I hereby claim:

• I am skritch on github.
• I am skritch (https://keybase.io/skritch) on keybase.
• I have a public key ASDQcppHLNIVBjh50QMaxC1GxHr4d5Zt-CVuZec556sgSAo

To claim this, I am signing this object:

skritch

from itertools import imap
import json

class Map(object):
    def __init__(self, iterable, steps=[]):
        """
        Construct an iterator that looks up items in the given iterable by index, key, field name, or calls
            a function on them.

        :param iterable: An iterable of "objects"

skritch

from alex import coliseum

c = coliseum.Coliseum(radius=50)
Cpillar=coliseum.Pillar(textures=basalt) # these pillars are all exactly the same object
# silly version
map(c.append(Cpillar, _), [
  (-40, 0),
  (-30, -30),
  (0, -40)
  ]