@Test public void testCreateAssetWithCSVStorage() { String sql = "CREATE ASSET user_asset (" + "id int," + "name string," + "designation string" + ")" + " WITH STORAGE TYPE CSV " + "FIELDS DELIMITED BY ',' " + "RECORDS DELIMITED BY \"\\n\""; LogicalPlan plan = getLogicalPlan(sql); CreateAsset actual = plan.getCreateAsset(); CreateAsset expected = buildCreateAssetCSV(); assertEquals(expected, actual); }
public CreateAsset getCreateAsset() { return createAsset; }
LogicalPlan extends TreeNode implements QueryItemInterface { public CreateAsset getCreateAsset() { return createAsset; } }
LogicalPlan extends TreeNode implements QueryItemInterface { public CreateAsset getCreateAsset() { return createAsset; } LogicalPlan(String description); }
LogicalPlan extends TreeNode implements QueryItemInterface { public CreateAsset getCreateAsset() { return createAsset; } LogicalPlan(String description); TreeNode getCurrentNode(); void setCurrentNode(TreeNode currentNode); Query getQuery(); void setQuery(Query query); CreateFunction getCreateFunction(); void setCreateFunction(CreateFunction createFunction); ClassName getClassName(); void setClassName(ClassName className); Insert getInsert(); void setInsert(Insert insert); CallFunction getCallFunction(); void setCallFunction(CallFunction callFunction); CreateAsset getCreateAsset(); void setCreateAsset(CreateAsset createAsset); DeleteFunction getDeleteFunction(); void setDeleteFunction(DeleteFunction deleteFunction); DropAsset getDropAsset(); void setDropAsset(DropAsset dropAsset); UpgradeFunction getUpgradeFunction(); void setSmartCnrtDeploy(SmartCnrtDeploy smartCnrtDeploy); SmartCnrtDeploy getSmartCnrtDeploy(); void setUpgradeFunction(UpgradeFunction upgradeFunction); void setCreateUser(CreateUser createUser); CreateUser getCreateUser(); SQLType getType(); void setType(SQLType type); @Override Object clone(); }
LogicalPlan extends TreeNode implements QueryItemInterface { public CreateAsset getCreateAsset() { return createAsset; } LogicalPlan(String description); TreeNode getCurrentNode(); void setCurrentNode(TreeNode currentNode); Query getQuery(); void setQuery(Query query); CreateFunction getCreateFunction(); void setCreateFunction(CreateFunction createFunction); ClassName getClassName(); void setClassName(ClassName className); Insert getInsert(); void setInsert(Insert insert); CallFunction getCallFunction(); void setCallFunction(CallFunction callFunction); CreateAsset getCreateAsset(); void setCreateAsset(CreateAsset createAsset); DeleteFunction getDeleteFunction(); void setDeleteFunction(DeleteFunction deleteFunction); DropAsset getDropAsset(); void setDropAsset(DropAsset dropAsset); UpgradeFunction getUpgradeFunction(); void setSmartCnrtDeploy(SmartCnrtDeploy smartCnrtDeploy); SmartCnrtDeploy getSmartCnrtDeploy(); void setUpgradeFunction(UpgradeFunction upgradeFunction); void setCreateUser(CreateUser createUser); CreateUser getCreateUser(); SQLType getType(); void setType(SQLType type); @Override Object clone();  }