Summary: 41 instances, 38 unique Text Count //TODO - complete impl 3 //TODO - work with SparkR devs to make this configurable and reuse RBackend 1 // TODO look into the possibility of reusing SerDe from R implementation 1 case _ => throw new Exception("Text files with more than 30 columns currently not supported") //TODO - if requirement comes up, generate code for additional columns 1 //TODO - add boolean instead of int in the backend 1 throw new NotImplementedException(); //TODO - implement 2 // TODO: We don't know whether accumulator variable is used before restart. We just start accumuator server for safety. 1 //TODO - add perf suite for subquery 1 @rem TODO: this check will fail if "--exe" only exists in the argument list of user application. 1 # TODO - add perf suite for subquery 1 // TODO - work with SparkR devs to make this configurable and reuse RBackendHandler 1 public DataFrame Join(DataFrame otherDataFrame, string[] joinColumnNames) // TODO: need aliasing for self join 1 public DataFrame Join(DataFrame otherDataFrame, string joinColumnName) // TODO: need aliasing for self join 1 else // {name: age, type: bigint,...} // TODO: validate more JTokenType other than Object 1 //TODO - add this method if needed to convert Row to collection of T 1 paramtersBytes.Add(SerDe.ToBytes(((IEnumerable)parameter).Count())); //TODO - Count() will traverse the collection - change interface? 1 //TODO - add perf suite for subquery 1 //TODO - remove this constructor after fixing unit tests that reference this 1 paramtersBytes.Add(SerDe.ToBytes(((IEnumerable)parameter).Count())); //TODO - Count() will traverse the collection - change interface? 1 public class SerDe //TODO - add ToBytes() for other types 1 elementType as StructType ?? convertArrayTypeToStructTypeFunc(elementType, valueOfArray.Length)).Values; // TODO: this part may have some problems, not verified 1 // TODO Enable these convenience functions if needed 1 //TODO - complete the impl 1 internal static byte[] GetTypeId(Type type) //TODO - support other types 1 // TODO: Types not handled right now include 1 // TODO verification should not depends on the output of worker 1 //TODO parameter Dictionary options is not used right now - it is meant to be passed on to data sources 1 /// TODO: move to scala and merge into DynamicPartitionKafkaRDD.getPartitions to remove above limitation 1 //setter is used only for testing...//TODO - refactor 1 public void Explain(bool extended = false) //TODO - GetQueryExecution is called in JVM twice if extendd = true - fix that 1 internal bool timingOut = false; // FIXME: set timingOut to true for those timeouted keys 1 //TODO - use annotation type 1 // fetch names of includes - not used //TODO - complete the impl 1 switch (typeAsChar) //TODO - add support for other types 1 //TODO - give generic types a better id 1 paramtersBytes.Add(SerDe.ToBytes(((IEnumerable)parameter).Count())); //TODO - Count() will traverse the collection - change interface? 1 /// # TODO: add control over map-side aggregation 1 //TODO - the following section is a copy of the same functionality in SQLContext..refactoring needed 1