MCPcopy Create free account

hub / github.com/data-integrations/wrangler / functions

Functions3,047 in github.com/data-integrations/wrangler

↓ 2 callersMethodgetUrl
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/schema/DataModelUrlRequest.java:31
↓ 2 callersMethodgetVersions
(HttpRequest request, HttpResponder responder, @PathParam("context") String context)
wrangler-core/src/test/java/io/cdap/wrangler/clients/SchemaRegistryClientTest.java:141
↓ 2 callersMethodgetWeight
()
wrangler-core/src/main/java/io/cdap/wrangler/sampling/Reservoir.java:131
↓ 2 callersMethodgetWorkspace
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/WorkspaceDetail.java:54
↓ 2 callersMethodgetWorkspaceSummary
Get the summary for the workspace rows
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/AbstractDirectiveHandler.java:220
↓ 2 callersMethodhasAlias
Checks if the directive is aliased. @param directive to be checked for aliasing. @return true if the directive has an alias, false otherwise.
wrangler-api/src/main/java/io/cdap/wrangler/api/DirectiveAlias.java:31
↓ 2 callersMethodinit
(HandlerContext handlerContext)
wrangler-core/src/test/java/io/cdap/directives/external/InvokeHttpTest.java:67
↓ 2 callersMethodinit
(ExecutorContext context)
wrangler-core/src/main/java/io/cdap/wrangler/expression/ELContext.java:94
↓ 2 callersMethodinitClientReturnResponse
(ADLStoreClient client, String path)
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSHandler.java:172
↓ 2 callersMethodisDateTime
(List<Map<Pattern, String>> patternGroupList, String value)
wrangler-core/src/main/java/io/cdap/wrangler/dq/DateTimePattern.java:105
↓ 2 callersMethodisLeft
(Coordinates vertex0, Coordinates vertex1, Coordinates gpC)
wrangler-core/src/main/java/io/cdap/functions/GeoFences.java:117
↓ 2 callersMethoditerator
Returns an iterator to the list of token groups maintained by this object. @return iterator to the list of tokens maintained.
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:112
↓ 2 callersMethodkeysToLower
This function lowers the keys of the json. it applies this transformation recurively. @param element to be transformed. @return modified element.
wrangler-core/src/main/java/io/cdap/functions/JsonFunctions.java:144
↓ 2 callersMethodlabel
@return Label associated with the token. Label provides a way to override the usage description for this <code>TokenDefinition</code>. If a label is n
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/TokenDefinition.java:61
↓ 2 callersMethodline
Returns the source line number these arguments were parsed from. @return the source line number.
wrangler-api/src/main/java/io/cdap/wrangler/api/Arguments.java:92
↓ 2 callersMethodlist
@return Returns an iterator to iterate through all the <code>DirectiveInfo</code> objects maintained within the registry.
wrangler-core/src/main/java/io/cdap/wrangler/registry/CompositeDirectiveRegistry.java:95
↓ 2 callersMethodlist
Scans the namespace to list all the keys applying the filter. @param filter to be applied on the data being returned. @return List of connections
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/connections/ConnectionStore.java:193
↓ 2 callersMethodlistDatasets
(HttpServiceRequest request, HttpServiceResponder responder, @PathParam("context")
wrangler-service/src/main/java/io/cdap/wrangler/service/bigquery/BigQueryHandler.java:130
↓ 2 callersMethodlistWorkspaces
Lists all the workspaces registered for a scope. @return List of workspaces.
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceDataset.java:193
↓ 2 callersMethodloadDrivers
(InputStream is, Map<String, DriverInfo> drivers)
wrangler-service/src/main/java/io/cdap/wrangler/service/database/DatabaseHandler.java:160
↓ 2 callersMethodloadPatterns
(String patternFileName, List<Map<Pattern, String>> patternParsers)
wrangler-core/src/main/java/io/cdap/wrangler/dq/DateTimePattern.java:46
↓ 2 callersMethodlookup
Looks up the code in the catalog. @param code to be looked up. @return StaticCatalog entry if found, else null.
wrangler-core/src/main/java/io/cdap/directives/lookup/StaticCatalog.java:41
↓ 2 callersMethodmatchPattern
(String value)
wrangler-core/src/main/java/io/cdap/directives/row/RecordRegexFilter.java:143
↓ 2 callersMethodmurmurHash
This function hashes an integer value. It is crucial to use different hash functions to partition data and the internal partitioning of data structur
wrangler-core/src/main/java/io/cdap/wrangler/sampling/MathUtils.java:33
↓ 2 callersMethodnextLine
Returns the next line in the wrapped <code>Reader. @return the next line from the input @throws NoSuchElementException if there is no line to return
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/BoundedLineInputStream.java:132
↓ 2 callersMethodparser
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1807
↓ 2 callersMethodpercentage
Computes percentages for each measure for a given column. @param column name of the column. @param sum denonminator for calculating percentages. @ret
wrangler-core/src/main/java/io/cdap/wrangler/statistics/ColumnMetric.java:82
↓ 2 callersMethodprecision
Get the precision of a decimal value
wrangler-core/src/main/java/io/cdap/wrangler/utils/DecimalTransform.java:98
↓ 2 callersMethodprocess
(List<String> input)
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:625
↓ 2 callersMethodreadArray
(JsonArray array, String path)
wrangler-core/src/main/java/io/cdap/wrangler/utils/JsonPathGenerator.java:98
↓ 2 callersMethodreadResource
(String name)
wrangler-core/src/main/java/io/cdap/directives/validation/ValidateStandard.java:99
↓ 2 callersMethodrename
Renames a column. The renamed column must not exist in the row. The comparision is case insensitive. @param row source record to be modified. @param
wrangler-core/src/main/java/io/cdap/wrangler/utils/ColumnConverter.java:49
↓ 2 callersMethodretrieveSample
(String namespace, String connectionName, SampleRequest sampleRequest)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/ConnectionDiscoverer.java:103
↓ 2 callersMethodsamplingProcess
()
wrangler-core/src/main/java/io/cdap/wrangler/sampling/Poisson.java:138
↓ 2 callersMethodsaveRecipe
(RecipeId recipeId, RecipeRow recipeRow, boolean failIfNotFound, StructuredTable table)
wrangler-storage/src/main/java/io/cdap/wrangler/store/recipe/RecipeStore.java:127
↓ 2 callersMethodsetCanWrangle
(boolean canWrangle)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/s3/S3ObjectInfo.java:114
↓ 2 callersMethodsetComplete
(NamespaceSummary namespace, StructuredTableContext context, UpgradeEntityType type
wrangler-storage/src/main/java/io/cdap/wrangler/store/upgrade/UpgradeStore.java:152
↓ 2 callersMethodsetDescription
(String description)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:123
↓ 2 callersMethodsetDisplaySize
(long displaySize)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:91
↓ 2 callersMethodsetField
( com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1260
↓ 2 callersMethodsetGroup
(String group)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:86
↓ 2 callersMethodsetId
<pre> Unique ID number for this person. </pre> <code>int32 id = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1445
↓ 2 callersMethodsetInsights
(JsonObject insights)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/Workspace.java:157
↓ 2 callersMethodsetName
(String name)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:118
↓ 2 callersMethodsetOwner
(String owner)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/s3/S3ObjectInfo.java:84
↓ 2 callersMethodsetPermission
(String permission)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:101
↓ 2 callersMethodsetPreconfigured
(boolean preconfigured)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/Connection.java:163
↓ 2 callersMethodsetProperties
(Map<String, String> properties)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:128
↓ 2 callersMethodsetRepeatedField
( com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1273
↓ 2 callersMethodsetType
(ConnectionType type)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:113
↓ 2 callersMethodsetUser
(String user)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:81
↓ 2 callersMethodtoFields
(Connection connection, long generation)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/connections/ConnectionStore.java:251
↓ 2 callersMethodtoFields
(SchemaRow schemaRow)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/schema/SchemaRegistry.java:359
↓ 2 callersMethodtoJsonString
Converts a {@link StructuredRecord} to a json string.
wrangler-core/src/main/java/io/cdap/wrangler/utils/StructuredRecordJsonConverter.java:67
↓ 2 callersMethodupdateWorkspace
Save the new workspace metadata @param workspaceId the workspace id @param workspace the new workspace meta to save
wrangler-storage/src/main/java/io/cdap/wrangler/store/workspace/WorkspaceStore.java:164
↓ 2 callersMethodvalidate
Should be called if this object is created through deserialization of user input. @throws IllegalArgumentException if the object is invalid.
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:62
↓ 2 callersMethodvalidateNamespace
(NamespaceSummary ns, String errorMessage)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/WorkspaceHandler.java:461
↓ 2 callersMethodvalidatePrecondition
(String precondition, Boolean isConditionSQL, FailureCollector collector)
wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java:546
↓ 2 callersMethodvalue
This method returns the token {@code value} based on the {@code name} specified in the argument. This method will attempt to convert the token into th
wrangler-core/src/main/java/io/cdap/wrangler/parser/MapArguments.java:167
↓ 2 callersMethodvalue
()
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/ColumnNameList.java:39
↓ 2 callersMethodvalue
()
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/Text.java:34
↓ 2 callersMethodvalue
()
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/Expression.java:34
↓ 2 callersMethodverify
(Class<? extends Directive> directive)
wrangler-test/src/main/java/io/cdap/wrangler/test/TestingRig.java:75
↓ 2 callersMethodvowelinstem
()
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:205
↓ 1 callersMethodCurrentTime
@return return current localtime.
wrangler-core/src/main/java/io/cdap/functions/DateAndTime.java:160
↓ 1 callersMethodIsNotNull
Returns true when an expression does not evaluate to the null value. @param value to be evaluated. @return true when not null, false otherwise.
wrangler-core/src/main/java/io/cdap/functions/Global.java:226
↓ 1 callersMethodMicroSecondsFromTime
Returns the microsecond portion of a time. If time is null, null will be returned. @param time of {@link LocalTime} type. @return microsecond portion
wrangler-core/src/main/java/io/cdap/functions/DateAndTime.java:356
↓ 1 callersMethodNanoSecondsFromTime
Returns the Nanosecond portion of a time. If time is null, null will be returned. @param time of {@link LocalTime} type. @return nanosecond portion o
wrangler-core/src/main/java/io/cdap/functions/DateAndTime.java:346
↓ 1 callersMethodParse
Parses a column or string to JSON. If the json string is invalid, this method will return a JsonNull @param json string representation of json. @retu
wrangler-core/src/main/java/io/cdap/functions/JsonFunctions.java:236
↓ 1 callersMethodacquire
()
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/DatasetProvider.java:27
↓ 1 callersMethodaddConnection
(String namespace, String connectionName, ConnectionCreationRequest request)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/ConnectionDiscoverer.java:75
↓ 1 callersMethodaddDefaultDirectives
Loads all the default system directives that are available with the system.
wrangler-core/src/main/java/io/cdap/wrangler/parser/UsageRegistry.java:144
↓ 1 callersMethodaddLoadableDirective
A Recipe can specify the pragma instructions for loading the directives dynamically. This method allows adding the new directive to be loaded as it's
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:216
↓ 1 callersMethodaddNewOutputFields
Method to add new fields from the given output to the map of fieldName --> value maintained for schema generation. A value is added to the map only if
wrangler-core/src/main/java/io/cdap/wrangler/schema/DirectiveOutputSchemaGenerator.java:54
↓ 1 callersMethodaddOrSetAtIndex
Adds or sets the value to the beginning. @param index at which the column need to be inserted. @param name of the field to be either set or added to
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:233
↓ 1 callersMethodaddPeople
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:2353
↓ 1 callersMethodaddPhones
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1610
↓ 1 callersMethodaddVersion
Recipe can specify the version of the grammar. This method allows one to extract and add the version to the <code>RecipeSymbol.</code> @param version
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:205
↓ 1 callersMethodbitMix
Bit-mixing for pseudo-randomization of integers (e.g., to guard against bad hash functions). Implementation is from Murmur's 32 bit finalizer. @param
wrangler-core/src/main/java/io/cdap/wrangler/sampling/MathUtils.java:60
↓ 1 callersMethodcalcHash
(InputStream is)
wrangler-core/src/test/java/io/cdap/directives/validation/ValidateStandardTest.java:80
↓ 1 callersMethodcheckConformance
Validate the given value against the loaded schema. It is up to the implementation to decide whether to return the first occurring error or all at onc
wrangler-core/src/main/java/io/cdap/directives/validation/conformers/Conformer.java:48
↓ 1 callersMethodcheckIfRowIsEmpty
(org.apache.poi.ss.usermodel.Row row)
wrangler-core/src/main/java/io/cdap/directives/parser/ParseExcel.java:232
↓ 1 callersMethodclientInputStream
(ADLStoreClient client, FileQueryDetails fileQueryDetails)
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSHandler.java:271
↓ 1 callersMethodcolumnName
(int number)
wrangler-core/src/main/java/io/cdap/directives/parser/ParseExcel.java:248
↓ 1 callersMethodconfigure
(HttpURLConnection urlConn)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/ConnectionDiscoverer.java:226
↓ 1 callersMethodconnectionExists
Returns true if connection identified by connectionName already exists.
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/connections/ConnectionStore.java:183
↓ 1 callersMethodconvertKey
(String key, Schema.Type type)
wrangler-core/src/main/java/io/cdap/wrangler/utils/StructuredRecordJsonConverter.java:154
↓ 1 callersMethodconvertResultSetToRow
(ResultSet resultSet)
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerHandler.java:338
↓ 1 callersMethodconvertToBytes
(List<Row> sample)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/WorkspaceDetail.java:43
↓ 1 callersMethodcreateGCSBucketWithFile
(String filePath)
wrangler-transform/src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java:148
↓ 1 callersMethodcreateSortByMap
()
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/recipe/RecipePageRequest.java:117
↓ 1 callersMethodcreateTestTables
(Connection conn)
wrangler-service/src/test/java/io/cdap/wrangler/service/database/DatabaseHandlerTest.java:149
↓ 1 callersMethodcreateTestUser
(Connection conn)
wrangler-service/src/test/java/io/cdap/wrangler/service/database/DatabaseHandlerTest.java:143
↓ 1 callersMethodcreateTokenGroup
<code>TokenGroup</code> is created for each directive in the recipe. This method creates a new <code>TokenGroup</code> by passing the <code>SourceInfo
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:183
↓ 1 callersMethoddecode
Decodes byte array of binary encoded AVRO into list of {@link Row}. This method will iterate through each of the AVRO schema fields and translate them
wrangler-core/src/main/java/io/cdap/wrangler/codec/BinaryAvroDecoder.java:58
↓ 1 callersMethoddecode
(byte[] bytes)
wrangler-core/src/main/java/io/cdap/wrangler/codec/ProtobufDecoderUsingDescriptor.java:50
↓ 1 callersMethoddecodeMap
(String name, Map<Object, Object> object, Schema key, Schema value)
wrangler-core/src/main/java/io/cdap/wrangler/utils/RecordConvertor.java:413
↓ 1 callersMethoddecodeMessage
(Message message, Row row, String root)
wrangler-core/src/main/java/io/cdap/wrangler/codec/ProtobufDecoderUsingDescriptor.java:64
↓ 1 callersMethoddecodeSimpleTypes
(String name, Object object, Schema schema)
wrangler-core/src/main/java/io/cdap/wrangler/utils/RecordConvertor.java:254
↓ 1 callersMethoddecodeUnion
(String name, Object object, List<Schema> schemas)
wrangler-core/src/main/java/io/cdap/wrangler/utils/RecordConvertor.java:423
← previousnext →601–700 of 3,047, ranked by callers