diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..ac8f968 --- /dev/null +++ b/.gitignore @@ -0,0 +1,20 @@ +# Compiled source # +################### +*.com +*.class +*.dll +*.exe +*.o +*.so +*.pyc + +# Logs and databases # +###################### +*.log + +# OS generated files # +###################### +.DS_Store* +ehthumbs.db +Icon? +Thumbs.db diff --git a/scripts/generate_timeuuid_example.pig b/scripts/generate_timeuuid_example.pig index 14b27e1..7f9522f 100644 --- a/scripts/generate_timeuuid_example.pig +++ b/scripts/generate_timeuuid_example.pig @@ -20,7 +20,7 @@ account_w_timeuuid = FOREACH account GENERATE first_name AS first_name, last_name AS last_name, GenerateTimeUUID() AS my_time_uuid; - + account_cassandra = FOREACH account_w_timeuuid GENERATE FLATTEN(ToCassandraBag(key, first_name, last_name, my_time_uuid)) AS ( key: chararray, first_name: chararray, diff --git a/udf/src/main/java/org/pygmalion/udf/ToCassandraBag.java b/udf/src/main/java/org/pygmalion/udf/ToCassandraBag.java index 58bcfaa..4b4d17b 100644 --- a/udf/src/main/java/org/pygmalion/udf/ToCassandraBag.java +++ b/udf/src/main/java/org/pygmalion/udf/ToCassandraBag.java @@ -93,7 +93,7 @@ public Schema outputSchema(Schema input) { builder.append(OUTPUT_DELIM); } } - + UDFContext context = UDFContext.getUDFContext(); Properties property = context.getUDFProperties(ToCassandraBag.class); property.setProperty(getSchemaKey(), builder.toString());