text:
@implementation PublicFunction

+ (NSMutableArray *)cropNinePartImages:(NSImage *)stretchImage
                     leftRightCapWidth:(NSUInteger)leftRightCapWidth
                     topBottomCapWidth:(NSUInteger)topBottomCapWidth
                       centerCapHeight:(NSUInteger)centerCapWidth
{
	if (nil == stretchImage) {
		return nil;
	}

	NSMutableArray *ninePartImages = [[NSMutableArray alloc] initWithCapacity:9];

	NSUInteger templateImageWidth = stretchImage.size.width;
	NSUInteger templateImageHeight = stretchImage.size.height;
    NSRect rect;
    NSImage *image = nil;

    //11
	rect = NSMakeRect(0, templateImageHeight-topBottomCapWidth, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //12
	rect = NSMakeRect((templateImageWidth - centerCapWidth)/2, templateImageHeight-topBottomCapWidth, centerCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //13
	rect = NSMakeRect(templateImageWidth-leftRightCapWidth, templateImageHeight-topBottomCapWidth, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //21
	rect = NSMakeRect(0, (templateImageHeight-centerCapWidth)/2, leftRightCapWidth, centerCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //22
    rect = NSMakeRect((templateImageWidth - centerCapWidth)/2, (templateImageHeight-centerCapWidth)/2, centerCapWidth, centerCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //23
	rect = NSMakeRect(templateImageWidth-leftRightCapWidth, (templateImageHeight-centerCapWidth)/2, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //31
	rect = NSMakeRect(0, 0, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

	//32
    rect = NSMakeRect((templateImageWidth - centerCapWidth)/2, 0, centerCapWidth, centerCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

	//33
    rect = NSMakeRect(templateImageWidth-leftRightCapWidth, 0, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

	return [ninePartImages autorelease];
}

+ (NSArray *)cropNinePartImages:(NSImage*)stretchImage
              leftRightCapWidth:(NSUInteger)leftRightCapWidth
              topBottomCapWidth:(NSUInteger)topBottomCapWidth
{
    if (nil == stretchImage) {
        return nil;
    }

    NSMutableArray *ninePartImages = [[NSMutableArray alloc] initWithCapacity:9];

    NSUInteger templateImageWidth = stretchImage.size.width;
    NSUInteger templateImageHeight = stretchImage.size.height;
    NSRect rect;
    NSImage *image = nil;

    //11
    rect = NSMakeRect(0, templateImageHeight-topBottomCapWidth, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //12
    rect = NSMakeRect(leftRightCapWidth, templateImageHeight-topBottomCapWidth, templateImageWidth - 2*leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //13
    rect = NSMakeRect(templateImageWidth-leftRightCapWidth, templateImageHeight-topBottomCapWidth, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //21
    rect = NSMakeRect(0, topBottomCapWidth, leftRightCapWidth, templateImageHeight - 2*topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //22
    rect = NSMakeRect(leftRightCapWidth, topBottomCapWidth, templateImageWidth - 2*leftRightCapWidth, templateImageHeight - 2*topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //23
    rect = NSMakeRect(templateImageWidth-leftRightCapWidth, topBottomCapWidth, leftRightCapWidth, templateImageHeight - 2*topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //31
    rect = NSMakeRect(0, 0, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //32
    rect = NSMakeRect(leftRightCapWidth, 0, templateImageWidth - 2*leftRightCapWidth, templateImageHeight - 2*topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    //33
    rect = NSMakeRect(templateImageWidth-leftRightCapWidth, 0, leftRightCapWidth, topBottomCapWidth);
    image = [[self cropImageFromRect:stretchImage rect:rect] retain];
    [ninePartImages addObject:image];
    [image release]; image = nil;

    return [ninePartImages autorelease];
}

+ (NSImage *)cropImageFromRect:(NSImage *)image rect:(NSRect)rect
{
    NSImage *subImage = [[NSImage alloc] initWithSize:rect.size];
    NSRect drawRect = NSZeroRect;
    drawRect.size = rect.size;

    [subImage lockFocus];
    [image drawInRect:drawRect
             fromRect:rect
            operation:NSCompositeSourceOver
             fraction:1.0f];
    [subImage unlockFocus];
    return [subImage autorelease];
}

+ (NSImage *)tileNinePartImage:(NSArray*)ninePartImages imageSize:(NSSize)imageSize
{
    if (imageSize.width == 0 || imageSize.height == 0) {
        return nil;
    }

    if (ninePartImages == nil || [ninePartImages count] <= 0) {
        return nil;
    }

	NSImage *resultImage = [[NSImage alloc] initWithSize:imageSize];
	NSRect boundsRect = NSMakeRect(0, 0, imageSize.width, imageSize.height);

	[resultImage lockFocus];
	NSDrawNinePartImage(boundsRect,
						[ninePartImages objectAtIndex:0],
						[ninePartImages objectAtIndex:1],
						[ninePartImages objectAtIndex:2],
						[ninePartImages objectAtIndex:3],
						[ninePartImages objectAtIndex:4],
						[ninePartImages objectAtIndex:5],
						[ninePartImages objectAtIndex:6],
						[ninePartImages objectAtIndex:7],
						[ninePartImages objectAtIndex:8],
						NSCompositeSourceOver, 1.0, NO);
	[resultImage unlockFocus];
	return [resultImage autorelease];
}

+ (NSImage *)stretchableImage:(NSImage*)srcImage size:(NSSize)size edgeInsets:(NSEdgeInsets)insets
{
    void (^makeAreas)(NSRect, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *)
    = ^(NSRect srcRect, NSRect *tl, NSRect *tc, NSRect *tr, NSRect *ml, NSRect *mc, NSRect *mr, NSRect *bl, NSRect *bc, NSRect *br)
    {
        CGFloat w = NSWidth(srcRect);
        CGFloat h = NSHeight(srcRect);
        CGFloat cw = w - insets.left - insets.right;
        CGFloat ch = h - insets.top - insets.bottom;

        CGFloat x0 = NSMinX(srcRect);
        CGFloat x1 = x0 + insets.left;
        CGFloat x2 = NSMaxX(srcRect) - insets.right;

        CGFloat y0 = NSMinY(srcRect);
        CGFloat y1 = y0 + insets.bottom;
        CGFloat y2 = NSMaxY(srcRect) - insets.top;

        *tl = NSMakeRect(x0, y2, insets.left, insets.top);
        *tc = NSMakeRect(x1, y2, cw, insets.top);
        *tr = NSMakeRect(x2, y2, insets.right, insets.top);

        *ml = NSMakeRect(x0, y1, insets.left, ch);
        *mc = NSMakeRect(x1, y1, cw, ch);
        *mr = NSMakeRect(x2, y1, insets.right, ch);

        *bl = NSMakeRect(x0, y0, insets.left, insets.bottom);
        *bc = NSMakeRect(x1, y0, cw, insets.bottom);
        *br = NSMakeRect(x2, y0, insets.right, insets.bottom);
    };

    NSRect rect = NSMakeRect(0, 0, size.width, size.height);

    // Source rects
    NSRect srcRect = (NSRect){NSZeroPoint, srcImage.size};
    NSRect srcTopL, srcTopC, srcTopR, srcMidL, srcMidC, srcMidR, srcBotL, srcBotC, srcBotR;
    makeAreas(srcRect, &srcTopL, &srcTopC, &srcTopR, &srcMidL, &srcMidC, &srcMidR, &srcBotL, &srcBotC, &srcBotR);

    // Destinations rects
    NSRect dstTopL, dstTopC, dstTopR, dstMidL, dstMidC, dstMidR, dstBotL, dstBotC, dstBotR;
    makeAreas(rect, &dstTopL, &dstTopC, &dstTopR, &dstMidL, &dstMidC, &dstMidR, &dstBotL, &dstBotC, &dstBotR);

    NSRect srcRects[] = {srcTopL, srcTopC, srcTopR, srcMidL, srcMidC, srcMidR, srcBotL, srcBotC, srcBotR};
    NSRect dstRects[] = {dstTopL, dstTopC, dstTopR, dstMidL, dstMidC, dstMidR, dstBotL, dstBotC, dstBotR};
    NSMutableArray *partImgs = [NSMutableArray arrayWithCapacity:9];
    for (int i=0;i<9;i++)
    {
        NSRect aSrcRect = srcRects[i];
        NSRect aDstRect = dstRects[i];

        NSImage *partImg = [[NSImage alloc] initWithSize:aSrcRect.size];
        [partImg lockFocus];
        [srcImage drawAtPoint:NSZeroPoint fromRect:aSrcRect operation:NSCompositeCopy fraction:1.0];
        [partImg setSize:aDstRect.size];
        [partImg unlockFocus];
        [partImgs addObject:partImg];
        [partImg release]; partImg = nil;
    }

    // Draw
    NSImage *resultImg = [[NSImage alloc] initWithSize:rect.size];
    [resultImg lockFocus];
    NSDrawNinePartImage(rect,
                        [partImgs objectAtIndex:0],
                        [partImgs objectAtIndex:1],
                        [partImgs objectAtIndex:2],
                        [partImgs objectAtIndex:3],
                        [partImgs objectAtIndex:4],
                        [partImgs objectAtIndex:5],
                        [partImgs objectAtIndex:6],
                        [partImgs objectAtIndex:7],
                        [partImgs objectAtIndex:8],
                        NSCompositeSourceOver, 1, NO);
    [resultImg unlockFocus];
    return [resultImg autorelease];
}

+ (NSArray *)ninePartWithImage:(NSImage*)img size:(NSSize)size edgeInsets:(LZEdgeInsets)insets
{
    void (^makeAreas)(NSRect, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *, NSRect *)
    = ^(NSRect srcRect, NSRect *tl, NSRect *tc, NSRect *tr, NSRect *ml, NSRect *mc, NSRect *mr, NSRect *bl, NSRect *bc, NSRect *br)
    {
        CGFloat w = NSWidth(srcRect);
        CGFloat h = NSHeight(srcRect);
        CGFloat cw = w - insets.left - insets.right;
        CGFloat ch = h - insets.top - insets.bottom;

        CGFloat x0 = NSMinX(srcRect);
        CGFloat x1 = x0 + insets.left;
        CGFloat x2 = NSMaxX(srcRect) - insets.right;

        CGFloat y0 = NSMinY(srcRect);
        CGFloat y1 = y0 + insets.bottom;
        CGFloat y2 = NSMaxY(srcRect) - insets.top;

        *tl = NSMakeRect(x0, y2, insets.left, insets.top);
        *tc = NSMakeRect(x1, y2, cw, insets.top);
        *tr = NSMakeRect(x2, y2, insets.right, insets.top);

        *ml = NSMakeRect(x0, y1, insets.left, ch);
        *mc = NSMakeRect(x1, y1, cw, ch);
        *mr = NSMakeRect(x2, y1, insets.right, ch);

        *bl = NSMakeRect(x0, y0, insets.left, insets.bottom);
        *bc = NSMakeRect(x1, y0, cw, insets.bottom);
        *br = NSMakeRect(x2, y0, insets.right, insets.bottom);
    };

    NSRect rect = NSMakeRect(0, 0, size.width, size.height);

    // Source rects
    NSRect srcRect = (NSRect){NSZeroPoint, img.size};
    NSRect srcTopL, srcTopC, srcTopR, srcMidL, srcMidC, srcMidR, srcBotL, srcBotC, srcBotR;
    makeAreas(srcRect, &srcTopL, &srcTopC, &srcTopR, &srcMidL, &srcMidC, &srcMidR, &srcBotL, &srcBotC, &srcBotR);

    // Destinations rects
    NSRect dstTopL, dstTopC, dstTopR, dstMidL, dstMidC, dstMidR, dstBotL, dstBotC, dstBotR;
    makeAreas(rect, &dstTopL, &dstTopC, &dstTopR, &dstMidL, &dstMidC, &dstMidR, &dstBotL, &dstBotC, &dstBotR);

    NSRect srcRects[] = {srcTopL, srcTopC, srcTopR, srcMidL, srcMidC, srcMidR, srcBotL, srcBotC, srcBotR};
    NSRect dstRects[] = {dstTopL, dstTopC, dstTopR, dstMidL, dstMidC, dstMidR, dstBotL, dstBotC, dstBotR};
    NSMutableArray *partImgs = [NSMutableArray arrayWithCapacity:9];
    for (int i=0; i<9; i++)
    {
        NSRect aSrcRect = srcRects[i];
        NSRect aDstRect = dstRects[i];

        NSImage *partImg = [[NSImage alloc] initWithSize:aSrcRect.size];
        [partImg lockFocus];
        [img drawAtPoint:NSZeroPoint fromRect:aSrcRect operation:NSCompositeCopy fraction:1.0];
        [partImg setSize:aDstRect.size];
        [partImg unlockFocus];
        [partImgs addObject:partImg];
        [partImg release]; partImg = nil;
    }

    return partImgs;
}
@end


text:
This template deploys Nagios Core, a host/service/network monitoring solution released under the GNU General Public License. This template also provisions a storage account, virtual network, public IP addresses and network interfaces required by the installation.

Visit the Nagios homepage at http://www.nagios.org for documentation, new releases, bug reports, information on discussion forums, and more.

The template requires the following parameters:

| Name   | Description    |
|:--- |:---|
| storageAccountName | Unique namespace for a new storage account where the virtual machine's disks will be placed (cannot be an existing storage account) |
| adminUsername  | Admin user name for the virtual machine  |
| adminPassword  | Admin password for the virtual machine  |
| location | Location where the corresponding Azure artifacts will be created |
| virtualNetworkName | Name of virtual network |
| subnetName | Name of the virtual network subnet |
| addressPrefix | The IP address mask used by the virtual network |
| subnetPrefix | The subnet mask used by the virtual network subnet |
| domainName | Domain name of the publicly accessible Apache web server hosting Nagios |
| tshirtSize | T-shirt size of the Nagios deployment |

Topology
--------
The Nagios deployment topology is comprised of a single VM instance that can be customized and scaled up using the _tshirtSize_ parameter. The following table outlines the VM characteristics for each supported t-shirt size:

| T-Shirt Size | VM Size | CPU Cores | Memory |
|:--- |:---|:---|:---|
| Small | Standard_A1 | 1 | 1.75 GB |
| Medium | Standard_D1 | 1 | 3.5 GB |
| Large | Standard_D2 | 2 | 7 GB |
| XLarge | Standard_D3 | 4 | 14 GB |
| XXLarge | Standard_D3 | 8 | 28 GB |

##Known Issues and Limitations
- A single instance installation Nagios Core is performed by the template
- This template does not install any monitoring targets

redpajama_set_name: RedPajamaGithub


text:
function F = acoth(F, varargin)
%ACOTH   Inverse hyperbolic cotangent of a CHEBFUN.
%   ACOTH(F) computes the inverse hyperbolic cotangent of the CHEBFUN F.
%
%   ACOTH(F, PREF) does the same but uses the CHEBFUNPREF object PREF when
%   computing the composition.
%
% See also COTH.

% Copyright 2016 by The University of Oxford and The Chebfun Developers. See
% http://www.chebfun.org/ for Chebfun information.

% Call the compose method:
F = compose(F, @acoth, varargin{:});

end


text:
<!--
@license
Copyright (c) 2016 The Polymer Project Authors. All rights reserved.
This code may only be used under the BSD style license found at http://polymer.github.io/LICENSE.txt
The complete set of authors may be found at http://polymer.github.io/AUTHORS.txt
The complete set of contributors may be found at http://polymer.github.io/CONTRIBUTORS.txt
Code distributed by Google as part of the polymer project is also
subject to an additional IP rights grant found at http://polymer.github.io/PATENTS.txt
-->

<link rel="import" href="../bower_components/polymer/polymer.html">

<dom-module id="my-category-data">

  <script>
  (function() {
    var categoryList = [
      {
        path_name: 'winter_2016',
        edition: 'Winter 2016',
        pdf: "../data/pdfs/16w.pdf"
            },
      {
        path_name: 'spring_2016',
        edition: 'Spring 2016',
        pdf: "../data/pdfs/16s.pdf"
            }
    ];

    Polymer({

      is: 'my-category-data',

      properties: {

        categoryName: String,

        itemName: String,

        categories: {
          type: Array,
          value: categoryList,
          readOnly: true,
          notify: true
        },

        category: {
          type: Object,
          computed: '_computeCategory(categoryName)',
          notify: true
        },

        item: {
          type: Object,
          computed: '_computeItem(category.items, itemName)',
          notify: true
        },

        failure: {
          type: Boolean,
          notify: true,
          readOnly: true
        }
      },

      _getCategoryObject: function(categoryName) {
        console.log(categoryName);
        for (var i = 0, c; c = this.categories[i]; ++i) {
          if (c.path_name === categoryName) {
            console.log(c);
            return c;
          }
        }
        return null;
      },

      _computeCategory: function(categoryName) {
        console.log(categoryName);
        // Fetch the items of the category. Note that the fetch is asynchronous,
        // which means `category.items` may not be set initially (but that path
        // will be notified when the fetch completes).
        var categoryObj = this._getCategoryObject(categoryName);
        this._fetchItems(categoryObj, 1);
        return categoryObj;
      },

      _computeItem: function(items, itemName) {
        console.log(itemName);
        for (var i = 0, item; item = items[i]; ++i) {
          if (item.path_title === itemName) {
            return item;
          }
        }
      },

      _fetchItems: function(category, attempts) {
        this._setFailure(false);
        // Only fetch the items of a category if it has not been previously set.
        console.log(category);
        console.log(category.items)
        if (!category || category.items) {
          return;
        }
        console.log('getting stuff')
        this._getResource({
          url: '/data/' + category.path_name + '.json',
          onLoad: function(e) {
            console.log('got stuff?')
            this.set('category.items', JSON.parse(e.target.responseText));

          },
          onError: function(e) {
            this._setFailure(true);
            console.log('fail');
          }
        }, attempts);
      },

      _getResource: function(rq, attempts) {
        var xhr = new XMLHttpRequest();
        xhr.addEventListener('load', rq.onLoad.bind(this));
        xhr.addEventListener('error', function(e) {
          // Flaky connections might fail fetching resources
          if (attempts > 1) {
            this.debounce('_getResource', this._getResource.bind(this, rq, attempts - 1), 200);
          } else {
            rq.onError.call(this, e);
          }
        }.bind(this));

        xhr.open('GET', rq.url);
        xhr.send();
      },

      refresh: function() {
        if (this.categoryName) {
          // Try at most 3 times to get the items.
          this._fetchItems(this._getCategoryObject(this.categoryName), 3);
        }
      }

    });

  })();
  </script>

</dom-module>


text:
#include <private/autogen/config.h>
#include <hwloc/autogen/config.h>
#include <private/solaris-chiptype.h>
#include <stdlib.h>
#include <strings.h>

#ifdef HAVE_PICL_H
#include <sys/systeminfo.h>
#include <picl.h>

/*****************************************************************************
   Order of this list is important for the assign_value and
   assign_string_value routines
*****************************************************************************/

static const char* items[] = {
  "clock-frequency",
  "cpu-mhz",
  "ecache-size",
  "l2-cache-size",
  "sectored-l2-cache-size",
  "implementation#",
  "manufacturer#",
  "compatible",
  "ProcessorType",
  "vendor-id",
  "brand-string"
};

#define NUM_ITEMS (sizeof(items) / sizeof(items[0]))

/*****************************************************************************
SPARC strings for chip modes and implementation
*****************************************************************************/
static const char* sparc_modes[] = {
    "UNKNOWN",
    "SPITFIRE",
    "BLACKBIRD",
    "CHEETAH",
    "SPARC64_VI",
    "T1",
    "T2",
    "SPARC64_VII",
    "ROCK"
};

/*****************************************************************************
Default values are for Unknown so we can build up from there.
*****************************************************************************/

static long dss_chip_mode         = MODE_UNKNOWN;
static long dss_chip_impl         = IMPL_SPITFIRE;
static long dss_chip_cache        = TWO_MEG_CACHE;
static long dss_chip_manufacturer = TI_MANUFACTURER;
static long long dss_chip_speed   = SPITFIRE_SPEED;
static char dss_chip_type[PICL_PROPNAMELEN_MAX];
static char dss_chip_model[PICL_PROPNAMELEN_MAX];
static int  called_cpu_probe      = 0;

/*****************************************************************************
Assigns values based on the value of index.  For this reason, the order of
the items array is important.
*****************************************************************************/
static void assign_value(int index, long long val) {
  if (index == 0) {  /* clock-frequency */
    dss_chip_speed = val;
  }
  if (index == 1) {  /* cpu-mhz */
    dss_chip_speed = val * 1000000; /* Scale since value was in MHz */
  }
  else if ((index >= 2) && (index <= 4)) {
    /* ecache-size, l2-cache-size, sectored-l2-cache-size */
    dss_chip_cache = val;
  }
  else if (index == 5) {
    /* implementation#  T1, T2, and Rock do not have this, see RFE 6615268 */
    dss_chip_impl = val;
    if (dss_chip_impl == IMPL_SPITFIRE) {
      dss_chip_mode = 1;
    }
    else if ((dss_chip_impl >= IMPL_BLACKBIRD) &&
             (dss_chip_impl <= IMPL_HUMMINGBIRD)) {
      dss_chip_mode = 2;
    }
    else if ((dss_chip_impl >= IMPL_CHEETAH) &&
             (dss_chip_impl <= IMPL_PANTHER)) {
      dss_chip_mode = 3;
    }
    else if (dss_chip_impl == IMPL_SPARC64_VI) {
      dss_chip_mode = 4;
    }
    else if (dss_chip_impl == IMPL_NIAGARA) {
      dss_chip_mode = 5;
    }
    else if (dss_chip_impl == IMPL_NIAGARA_2) {
      dss_chip_mode = 6;
    }
    else if (dss_chip_impl == IMPL_SPARC64_VII) {
      dss_chip_mode = 7;
    }
    else if (dss_chip_impl == IMPL_ROCK) {
      dss_chip_mode = 8;
    }
  }
  else if (index == 6) { /* manufacturer# */
    dss_chip_manufacturer = val;
  }
}

/*****************************************************************************
Assigns values based on the value of index.  For this reason, the order of
the items array is important.
*****************************************************************************/
static void assign_string_value(int index, char* string_val) {
  if (index == 7) { /* compatible */
    if (strncasecmp(string_val, "FJSV,SPARC64-VI",
                    PICL_PROPNAMELEN_MAX) == 0) {
      dss_chip_mode = 4;
    }
    else if (strncasecmp(string_val, "SUNW,UltraSPARC-T1",
                         PICL_PROPNAMELEN_MAX) == 0) {
      dss_chip_mode = 5;
    }
    else if (strncasecmp(string_val, "SUNW,UltraSPARC-T2",
                         PICL_PROPNAMELEN_MAX) == 0) {
      dss_chip_mode = 6;
    }
    else if (strncasecmp(string_val, "FJSV,SPARC64-VII",
                         PICL_PROPNAMELEN_MAX) == 0) {
      dss_chip_mode = 7;
    }
    else if (strncasecmp(string_val, "SUNW,Rock",
                         PICL_PROPNAMELEN_MAX) == 0) {
      dss_chip_mode = 8;
    }
  } else if (index == 8) {  /* ProcessorType */
      strncpy(&dss_chip_type[0], string_val, PICL_PROPNAMELEN_MAX);
  } else if (index == 10) { /* brand-string */
      strncpy(&dss_chip_model[0], string_val, PICL_PROPNAMELEN_MAX);
  }

}

/*****************************************************************************
Gets called by probe_cpu.  Cycles through the table values until we find
what we are looking for.
*****************************************************************************/
static void search_table(int index, picl_prophdl_t table_hdl) {

  picl_prophdl_t  col_hdl;
  picl_prophdl_t  row_hdl;
  picl_propinfo_t p_info;
  int             val;
  char            string_val[PICL_PROPNAMELEN_MAX];

  for (val = picl_get_next_by_col(table_hdl, &row_hdl); val != PICL_ENDOFLIST;
       val = picl_get_next_by_col(row_hdl, &row_hdl)) {
    if (val == PICL_SUCCESS) {
      for (col_hdl = row_hdl; val != PICL_ENDOFLIST;
           val = picl_get_next_by_row(col_hdl, &col_hdl)) {
        if (val == PICL_SUCCESS) {
          val = picl_get_propinfo(col_hdl, &p_info);
          if (val == PICL_SUCCESS) {
            if (p_info.type == PICL_PTYPE_CHARSTRING) {
              val = picl_get_propval(col_hdl, &string_val, sizeof(string_val));
              if (val == PICL_SUCCESS) {
                assign_string_value(index, string_val);
              }
            }
          }
        }
      }
    }
  }
}

/*****************************************************************************
Gets called by picl_walk_tree_by_class.  Then it cycles through the properties
until we find what we are looking for.  Once we are done, we return
PICL_WALK_TERMINATE to stop picl_walk_tree_by_class from traversing the tree.

Note that PICL_PTYPE_UNSIGNED_INT and PICL_PTYPE_INT can either be 4-bytes
or 8-bytes.
*****************************************************************************/
static int probe_cpu(picl_nodehdl_t node_hdl, void* dummy_arg __hwloc_attribute_unused) {

  picl_prophdl_t  p_hdl;
  picl_prophdl_t  table_hdl;
  picl_propinfo_t p_info;
  long long       long_long_val;
  unsigned int    uint_val;
  unsigned int    index;
  int             int_val;
  int             val;
  char            string_val[PICL_PROPNAMELEN_MAX];

  val = picl_get_first_prop(node_hdl, &p_hdl);
  while (val == PICL_SUCCESS) {
    called_cpu_probe = 1;
    val = picl_get_propinfo(p_hdl, &p_info);
    if (val == PICL_SUCCESS) {
      for (index = 0; index < NUM_ITEMS; index++) {
        if (strcasecmp(p_info.name, items[index]) == 0) {
          if (p_info.type == PICL_PTYPE_UNSIGNED_INT) {
            if (p_info.size == sizeof(uint_val)) {
              val = picl_get_propval(p_hdl, &uint_val, sizeof(uint_val));
              if (val == PICL_SUCCESS) {
                long_long_val = uint_val;
                assign_value(index, long_long_val);
              }
            }
            else if (p_info.size == sizeof(long_long_val)) {
              val = picl_get_propval(p_hdl, &long_long_val,
                                     sizeof(long_long_val));
              if (val == PICL_SUCCESS) {
                assign_value(index, long_long_val);
              }
            }
          }
          else if (p_info.type == PICL_PTYPE_INT) {
            if (p_info.size == sizeof(int_val)) {
              val = picl_get_propval(p_hdl, &int_val, sizeof(int_val));
              if (val == PICL_SUCCESS) {
                long_long_val = int_val;
                assign_value(index, long_long_val);
              }
            }
            else if (p_info.size == sizeof(long_long_val)) {
              val = picl_get_propval(p_hdl, &long_long_val,
                                     sizeof(long_long_val));
              if (val == PICL_SUCCESS) {
                assign_value(index, long_long_val);
              }
            }
          }
          else if (p_info.type == PICL_PTYPE_CHARSTRING) {
            val = picl_get_propval(p_hdl, &string_val, sizeof(string_val));
            if (val == PICL_SUCCESS) {
              assign_string_value(index, string_val);
            }
          }
          else if (p_info.type == PICL_PTYPE_TABLE) {
            val = picl_get_propval(p_hdl, &table_hdl, p_info.size);
            if (val == PICL_SUCCESS) {
              search_table(index, table_hdl);
            }
          }
          break;
        } else if (index == NUM_ITEMS-1) {
	  if (p_info.type == PICL_PTYPE_CHARSTRING) {
            val = picl_get_propval(p_hdl, &string_val, sizeof(string_val));
            if (val == PICL_SUCCESS) {
            }
	  }
	}
      }
    }

    val = picl_get_next_prop(p_hdl, &p_hdl);
  }
  return PICL_WALK_TERMINATE;
}

/*****************************************************************************
Initializes, gets the root, then walks the picl tree looking for information

Currently, the "core" class is only needed for OPL systems
*****************************************************************************/
char* hwloc_solaris_get_chip_type(void) {
  picl_nodehdl_t root;
  int            val;
  static char chip_type[PICL_PROPNAMELEN_MAX];

  val = picl_initialize();
  if (val != PICL_SUCCESS) { /* Can't initialize session with PICL daemon */
      return(NULL);
  }
  val = picl_get_root(&root);
  if (val != PICL_SUCCESS) {  /* Failed to get root node of the PICL tree */
      return(NULL);
  }
  val = picl_walk_tree_by_class(root, "cpu", (void *)NULL, probe_cpu);
  val = picl_walk_tree_by_class(root, "core", (void *)NULL, probe_cpu);
  picl_shutdown();

  if (called_cpu_probe) {
#if (defined HWLOC_X86_64_ARCH) || (defined HWLOC_X86_32_ARCH)
      /* PICL returns some corrupted chip_type strings on x86,
       * and CPUType only used on Sparc anyway, at least for now.
       * So we just ignore this attribute on x86. */
#else
      strncpy(chip_type, dss_chip_type, PICL_PROPNAMELEN_MAX);
#endif
  } else {
      /* no picl information on machine available */
      sysinfo(SI_HW_PROVIDER, chip_type, PICL_PROPNAMELEN_MAX);
  }
  return(chip_type);
}

/*****************************************************************************
Initializes, gets the root, then walks the picl tree looking for information

Currently, the "core" class is only needed for OPL systems
*****************************************************************************/
char *hwloc_solaris_get_chip_model(void) {

    if (called_cpu_probe) {
	if (dss_chip_mode != MODE_UNKNOWN) { /* SPARC chip */
	    strncpy(dss_chip_model, sparc_modes[dss_chip_mode],
		    PICL_PROPNAMELEN_MAX);
	}
    } else {
	/* no picl information on machine available */
	sysinfo(SI_PLATFORM, dss_chip_model, PICL_PROPNAMELEN_MAX);
    }
    return(dss_chip_model);
}

#else
char* hwloc_solaris_get_chip_type(void) {
  return NULL;
}
char *hwloc_solaris_get_chip_model(void) {
  return NULL;
}
#endif


text:
<?php

if (realpath (__FILE__) === realpath ($_SERVER["SCRIPT_FILENAME"]))
	exit ("Do not access this file directly.");

if (!class_exists ("c_ws_plugin__s2member_paypal_return"))
	{
		/**
		* s2Member's PayPal® Auto-Return/PDT handler.
		*
		* @package s2Member\PayPal
		* @since 3.5
		*/
		class c_ws_plugin__s2member_paypal_return
			{
				/**
				* Handles PayPal® Return URLs.
				*
				* @package s2Member\PayPal
				* @since 3.5
				*
				* @attaches-to ``add_action("init");``
				*
				* @return null|inner Return-value of inner routine.
				*/
				public static function paypal_return ()
					{
						if (!empty ($_GET["s2member_paypal_return"]))
							{
								return c_ws_plugin__s2member_paypal_return_in::paypal_return ();
							}
					}
			}
	}
?>


text:
import Control from './control';
import utils from './utils';

const name = 'along';

/*
 * Find point along line at given distance
 */
const action = function(control) {
  // Define control ids
  const idCancel = utils.getName([name, 'cancel'], control.prefix);
  const idDistance = utils.getName([name, 'distance'], control.prefix);
  const idForm = utils.getName([name, 'form'], control.prefix);
  const idOk = utils.getName([name, 'ok'], control.prefix);
  const idUnits = utils.getName([name, 'units'], control.prefix);

  const onOK = function() {
    try {
      // Gather line seleted
      const collection = utils.getCollection(control, 1, 1);
      const lines = utils.getLines(collection, 1, 1);
      const line = lines[0];

      // Gather form inputs
      const distance = utils.getFormNumber(idDistance, 'distance');
      const units = utils.getFormString(idUnits, 'units');

      // Collect polygons
      const output = turf.along(line, distance, {units});

      // Remove form and display results
      control.showForm();
      const inputs = {
        line: line,
        distance: distance,
        units: units,
      };
      control.toolbar.olturf.handler.callback(name, output, inputs);
    } catch (e) {
      control.showMessage(e);
    }
  };

  const onCancel = function() {
    control.showForm();
  };

  const controls = [
    utils.getControlNumber(idDistance,
        'Distance', 'Distance along the line', '0', 'any', '0'),
    utils.getControlSelect(idUnits,
        'Units', utils.getOptionsUnits()),
    utils.getControlInput(idOk, onOK, '', 'OK'),
    utils.getControlInput(idCancel, onCancel, '', 'Cancel'),
  ];

  control.showForm(controls, idForm);
};

export default {
  create: function(toolbar, prefix) {
    const title = 'Find point along line at given distance';
    return Control.create(toolbar, prefix, name, title, action);
  },
};


text:
package org.apache.carbondata.core.constants;

public final class CarbonCommonConstants {
  /**
   * integer size in bytes
   */
  public static final int INT_SIZE_IN_BYTE = 4;
  /**
   * short size in bytes
   */
  public static final int SHORT_SIZE_IN_BYTE = 2;
  /**
   * DOUBLE size in bytes
   */
  public static final int DOUBLE_SIZE_IN_BYTE = 8;
  /**
   * LONG size in bytes
   */
  public static final int LONG_SIZE_IN_BYTE = 8;
  /**
   * byte to KB conversion factor
   */
  public static final int BYTE_TO_KB_CONVERSION_FACTOR = 1024;
  /**
   * BYTE_ENCODING
   */
  public static final String BYTE_ENCODING = "ISO-8859-1";
  /**
   * measure meta data file name
   */
  public static final String MEASURE_METADATA_FILE_NAME = "/msrMetaData_";
  /**
   * location of the carbon member, hierarchy and fact files
   */
  public static final String STORE_LOCATION = "carbon.storelocation";
  /**
   * blocklet size in carbon file
   */
  public static final String BLOCKLET_SIZE = "carbon.blocklet.size";
  /**
   * Number of cores to be used
   */
  public static final String NUM_CORES = "carbon.number.of.cores";
  /**
   * carbon sort size
   */
  public static final String SORT_SIZE = "carbon.sort.size";
  /**
   * default location of the carbon member, hierarchy and fact files
   */
  public static final String STORE_LOCATION_DEFAULT_VAL = "../carbon.store";
  /**
   * the folder name of kettle home path
   */
  public static final String KETTLE_HOME_NAME = "carbonplugins";
  /**
   * CARDINALITY_INCREMENT_DEFAULT_VALUE
   */
  public static final int CARDINALITY_INCREMENT_VALUE_DEFAULT_VAL = 10;
  /**
   * default blocklet size
   */
  public static final String BLOCKLET_SIZE_DEFAULT_VAL = "120000";
  /**
   * min blocklet size
   */
  public static final int BLOCKLET_SIZE_MIN_VAL = 50;
  /**
   * max blocklet size
   */
  public static final int BLOCKLET_SIZE_MAX_VAL = 12000000;

  public static final String BLOCK_SIZE_DEFAULT_VAL = "1024";

  public static final int BLOCK_SIZE_MIN_VAL = 1;

  public static final int BLOCK_SIZE_MAX_VAL = 2048;
  /**
   * default value of number of cores to be used
   */
  public static final String NUM_CORES_DEFAULT_VAL = "2";
  /**
   * min value of number of cores to be used
   */
  public static final int NUM_CORES_MIN_VAL = 1;
  /**
   * max value of number of cores to be used
   */
  public static final int NUM_CORES_MAX_VAL = 32;
  /**
   * default carbon sort size
   */
  public static final String SORT_SIZE_DEFAULT_VAL = "100000";
  /**
   * min carbon sort size
   */
  public static final int SORT_SIZE_MIN_VAL = 1000;
  /**
   * carbon properties file path
   */
  public static final String CARBON_PROPERTIES_FILE_PATH = "../../../conf/carbon.properties";
  /**
   * CARBON_DDL_BASE_HDFS_URL
   */
  public static final String CARBON_DDL_BASE_HDFS_URL = "carbon.ddl.base.hdfs.url";
  /**
   * Load Folder Name
   */
  public static final String LOAD_FOLDER = "Segment_";
  /**
   * HDFSURL_PREFIX
   */
  public static final String HDFSURL_PREFIX = "hdfs://";
  /**
   * FS_DEFAULT_FS
   */
  public static final String FS_DEFAULT_FS = "fs.defaultFS";
  /**
   * BYTEBUFFER_SIZE
   */

  public static final int BYTEBUFFER_SIZE = 24 * 1024;
  /**
   * Average constant
   */
  public static final String AVERAGE = "avg";
  /**
   * Count constant
   */
  public static final String COUNT = "count";
  /**
   * SUM
   */
  public static final String SUM = "sum";
  /**
   * DUMMY aggregation function
   */
  public static final String DUMMY = "dummy";
  /**
   * MEMBER_DEFAULT_VAL
   */
  public static final String MEMBER_DEFAULT_VAL = "@NU#LL$!";
  /**
   * FILE STATUS IN-PROGRESS
   */
  public static final String FILE_INPROGRESS_STATUS = ".inprogress";
  /**
   * CARBON_BADRECORDS_LOCATION
   */
  public static final String CARBON_BADRECORDS_LOC = "carbon.badRecords.location";
  /**
   * CARBON_BADRECORDS_LOCATION_DEFAULT
   */
  public static final String CARBON_BADRECORDS_LOC_DEFAULT_VAL =
      "../unibi-solutions/system/carbon/badRecords";
  /**
   * HIERARCHY_FILE_EXTENSION
   */
  public static final String HIERARCHY_FILE_EXTENSION = ".hierarchy";
  /**
   * SORT_TEMP_FILE_LOCATION
   */
  public static final String SORT_TEMP_FILE_LOCATION = "sortrowtmp";
  /**
   * CARBON_RESULT_SIZE_DEFAULT
   */
  public static final String LEVEL_FILE_EXTENSION = ".level";
  /**
   * FACT_FILE_EXT
   */
  public static final String FACT_FILE_EXT = ".carbondata";
  /**
   * MEASUREMETADATA_FILE_EXT
   */
  public static final String MEASUREMETADATA_FILE_EXT = ".msrmetadata";
  /**
   * GRAPH_ROWSET_SIZE
   */
  public static final String GRAPH_ROWSET_SIZE = "carbon.graph.rowset.size";
  /**
   * GRAPH_ROWSET_SIZE_DEFAULT
   */
  public static final String GRAPH_ROWSET_SIZE_DEFAULT = "500";
  /**
   * Comment for TYPE_MYSQL
   */
  public static final String TYPE_MYSQL = "MYSQL";
  /**
   * Comment for TYPE_MSSQL
   */
  public static final String TYPE_MSSQL = "MSSQL";
  /**
   * Comment for TYPE_ORACLE
   */
  public static final String TYPE_ORACLE = "ORACLE";
  /**
   * Comment for TYPE_SYBASE
   */
  public static final String TYPE_SYBASE = "SYBASE";
  /**
   * SORT_INTERMEDIATE_FILES_LIMIT
   */
  public static final String SORT_INTERMEDIATE_FILES_LIMIT = "carbon.sort.intermediate.files.limit";
  /**
   * SORT_INTERMEDIATE_FILES_LIMIT_DEFAULT_VALUE
   */
  public static final String SORT_INTERMEDIATE_FILES_LIMIT_DEFAULT_VALUE = "20";
  /**
   * MERGERD_EXTENSION
   */
  public static final String MERGERD_EXTENSION = ".merge";
  /**
   * SORT_FILE_BUFFER_SIZE
   */
  public static final String SORT_FILE_BUFFER_SIZE = "carbon.sort.file.buffer.size";
  /**
   * no.of records after which counter to be printed
   */
  public static final String DATA_LOAD_LOG_COUNTER = "carbon.load.log.counter";
  /**
   * DATA_LOAD_LOG_COUNTER_DEFAULT_COUNTER
   */
  public static final String DATA_LOAD_LOG_COUNTER_DEFAULT_COUNTER = "500000";
  /**
   * SORT_FILE_WRITE_BUFFER_SIZE
   */
  public static final String CARBON_SORT_FILE_WRITE_BUFFER_SIZE =
      "carbon.sort.file.write.buffer.size";
  /**
   * SORT_FILE_WRITE_BUFFER_SIZE_DEFAULT_VALUE
   */
  public static final String CARBON_SORT_FILE_WRITE_BUFFER_SIZE_DEFAULT_VALUE = "50000";
  /**
   * Number of cores to be used while loading
   */
  public static final String NUM_CORES_LOADING = "carbon.number.of.cores.while.loading";
  /**
   * Number of cores to be used while compacting
   */
  public static final String NUM_CORES_COMPACTING = "carbon.number.of.cores.while.compacting";
  /**
   * Number of cores to be used for block sort
   */
  public static final String NUM_CORES_BLOCK_SORT = "carbon.number.of.cores.block.sort";
  /**
   * Default value of number of cores to be used for block sort
   */
  public static final String NUM_CORES_BLOCK_SORT_DEFAULT_VAL = "7";
  /**
   * Max value of number of cores to be used for block sort
   */
  public static final int NUM_CORES_BLOCK_SORT_MAX_VAL = 12;
  /**
   * Min value of number of cores to be used for block sort
   */
  public static final int NUM_CORES_BLOCK_SORT_MIN_VAL = 1;
  /**
   * CSV_READ_BUFFER_SIZE
   */
  public static final String CSV_READ_BUFFER_SIZE = "carbon.csv.read.buffersize.byte";
  /**
   * CSV_READ_BUFFER_SIZE
   */
  public static final String CSV_READ_BUFFER_SIZE_DEFAULT = "50000";
  /**
   * CSV_READ_COPIES
   */
  public static final String DEFAULT_NUMBER_CORES = "2";
  /**
   * CSV_FILE_EXTENSION
   */
  public static final String CSV_FILE_EXTENSION = ".csv";

  /**
   * LOG_FILE_EXTENSION
   */
  public static final String LOG_FILE_EXTENSION = ".log";

  /**
   * COLON_SPC_CHARACTER
   */
  public static final String COLON_SPC_CHARACTER = ":!@#COLON#@!:";
  /**
   * HASH_SPC_CHARATER
   */
  public static final String HASH_SPC_CHARACTER = "#!@:HASH:@!#";
  /**
   * SEMICOLON_SPC_CHARATER
   */
  public static final String SEMICOLON_SPC_CHARACTER = ";#!@:SEMIC:@!#;";
  /**
   * AMPERSAND_SPC_CHARATER
   */
  public static final String AMPERSAND_SPC_CHARACTER = "&#!@:AMPER:@!#&";
  /**
   * ATTHERATE_SPC_CHARATER
   */
  public static final String COMA_SPC_CHARACTER = ",#!:COMA:!#,";
  /**
   * HYPHEN_SPC_CHARACTER
   */
  public static final String HYPHEN_SPC_CHARACTER = "-#!:HYPHEN:!#-";
  /**
   * SORT_TEMP_FILE_EXT
   */
  public static final String SORT_TEMP_FILE_EXT = ".sorttemp";
  /**
   * CARBON_MERGE_SORT_READER_THREAD
   */
  public static final String CARBON_MERGE_SORT_READER_THREAD = "carbon.merge.sort.reader.thread";
  /**
   * CARBON_MERGE_SORT_READER_THREAD_DEFAULTVALUE
   */
  public static final String CARBON_MERGE_SORT_READER_THREAD_DEFAULTVALUE = "3";
  /**
   * IS_SORT_TEMP_FILE_COMPRESSION_ENABLED
   */
  public static final String IS_SORT_TEMP_FILE_COMPRESSION_ENABLED =
      "carbon.is.sort.temp.file.compression.enabled";
  /**
   * IS_SORT_TEMP_FILE_COMPRESSION_ENABLED_DEFAULTVALUE
   */
  public static final String IS_SORT_TEMP_FILE_COMPRESSION_ENABLED_DEFAULTVALUE = "false";
  /**
   * SORT_TEMP_FILE_NO_OF_RECORDS_FOR_COMPRESSION
   */
  public static final String SORT_TEMP_FILE_NO_OF_RECORDS_FOR_COMPRESSION =
      "carbon.sort.temp.file.no.of.records.for.compression";
  /**
   * SORT_TEMP_FILE_NO_OF_RECORD_FOR_COMPRESSION_DEFAULTVALUE
   */
  public static final String SORT_TEMP_FILE_NO_OF_RECORD_FOR_COMPRESSION_DEFAULTVALUE = "50";
  /**
   * DEFAULT_COLLECTION_SIZE
   */
  public static final int DEFAULT_COLLECTION_SIZE = 16;
  /**
   * CARBON_TIMESTAMP_DEFAULT_FORMAT
   */
  public static final String CARBON_TIMESTAMP_DEFAULT_FORMAT = "yyyy-MM-dd HH:mm:ss";
  /**
   * CARBON_TIMESTAMP_DEFAULT_FORMAT
   */
  public static final String CARBON_TIMESTAMP_FORMAT = "carbon.timestamp.format";
  /**
   * STORE_LOCATION_HDFS
   */
  public static final String STORE_LOCATION_HDFS = "carbon.storelocation.hdfs";
  /**
   * STORE_LOCATION_TEMP_PATH
   */
  public static final String STORE_LOCATION_TEMP_PATH = "carbon.tempstore.location";
  /**
   * IS_COLUMNAR_STORAGE_DEFAULTVALUE
   */
  public static final String IS_COLUMNAR_STORAGE_DEFAULTVALUE = "true";
  /**
   * DIMENSION_SPLIT_VALUE_IN_COLUMNAR_DEFAULTVALUE
   */
  public static final String DIMENSION_SPLIT_VALUE_IN_COLUMNAR_DEFAULTVALUE = "1";
  /**
   * IS_FULLY_FILLED_BITS_DEFAULT_VALUE
   */
  public static final String IS_FULLY_FILLED_BITS_DEFAULT_VALUE = "true";
  /**
   * IS_INT_BASED_INDEXER
   */
  public static final String AGGREAGATE_COLUMNAR_KEY_BLOCK = "aggregate.columnar.keyblock";
  /**
   * IS_INT_BASED_INDEXER_DEFAULTVALUE
   */
  public static final String AGGREAGATE_COLUMNAR_KEY_BLOCK_DEFAULTVALUE = "true";
  /**
   * ENABLE_QUERY_STATISTICS
   */
  public static final String ENABLE_QUERY_STATISTICS = "enable.query.statistics";
  /**
   * ENABLE_QUERY_STATISTICS_DEFAULT
   */
  public static final String ENABLE_QUERY_STATISTICS_DEFAULT = "false";
  /**
   * TIME_STAT_UTIL_TYPE
   */
  public static final String ENABLE_DATA_LOADING_STATISTICS = "enable.data.loading.statistics";
  /**
   * TIME_STAT_UTIL_TYPE_DEFAULT
   */
  public static final String ENABLE_DATA_LOADING_STATISTICS_DEFAULT = "false";
  /**
   * IS_INT_BASED_INDEXER
   */
  public static final String HIGH_CARDINALITY_VALUE = "high.cardinality.value";
  /**
   * IS_INT_BASED_INDEXER_DEFAULTVALUE
   */
  public static final String HIGH_CARDINALITY_VALUE_DEFAULTVALUE = "100000";
  /**
   * CONSTANT_SIZE_TEN
   */
  public static final int CONSTANT_SIZE_TEN = 10;
  /**
   * LEVEL_METADATA_FILE
   */
  public static final String LEVEL_METADATA_FILE = "levelmetadata_";
  /**
   * LOAD_STATUS SUCCESS
   */
  public static final String STORE_LOADSTATUS_SUCCESS = "Success";
  /**
   * LOAD_STATUS FAILURE
   */
  public static final String STORE_LOADSTATUS_FAILURE = "Failure";
  /**
   * LOAD_STATUS PARTIAL_SUCCESS
   */
  public static final String STORE_LOADSTATUS_PARTIAL_SUCCESS = "Partial Success";
  /**
   * LOAD_STATUS
   */
  public static final String CARBON_METADATA_EXTENSION = ".metadata";
  /**
   * COMMA
   */
  public static final String COMMA = ",";
  /**
   * UNDERSCORE
   */
  public static final String UNDERSCORE = "_";
  /**
   * POINT
   */
  public static final String POINT = ".";
  /**
   * File separator
   */
  public static final String FILE_SEPARATOR = "/";
  /**
   * MAX_QUERY_EXECUTION_TIME
   */
  public static final String MAX_QUERY_EXECUTION_TIME = "max.query.execution.time";
  /**
   * CARBON_TIMESTAMP
   */
  public static final String CARBON_TIMESTAMP = "dd-MM-yyyy HH:mm:ss";
  /**
   * NUMBER_OF_TRIES_FOR_LOAD_METADATA_LOCK
   */
  public static final int NUMBER_OF_TRIES_FOR_LOAD_METADATA_LOCK_DEFAULT = 3;
  /**
   * MAX_TIMEOUT_FOR_LOAD_METADATA_LOCK
   */
  public static final int MAX_TIMEOUT_FOR_LOAD_METADATA_LOCK_DEFAULT = 5;
  /**
   * NUMBER_OF_TRIES_FOR_LOAD_METADATA_LOCK
   */
  public static final String NUMBER_OF_TRIES_FOR_LOAD_METADATA_LOCK =
      "carbon.load.metadata.lock.retries";
  /**
   * MAX_TIMEOUT_FOR_LOAD_METADATA_LOCK
   */
  public static final String MAX_TIMEOUT_FOR_LOAD_METADATA_LOCK =
      "carbon.load.metadata.lock.retry.timeout.sec";
  /**
   * MARKED_FOR_DELETION
   */
  public static final String MARKED_FOR_DELETE = "Marked for Delete";
  public static final String MARKED_FOR_UPDATE = "Marked for Update";
  public static final String STRING_TYPE = "StringType";
  public static final String INTEGER_TYPE = "IntegerType";
  public static final String LONG_TYPE = "LongType";
  public static final String DOUBLE_TYPE = "DoubleType";
  public static final String FLOAT_TYPE = "FloatType";
  public static final String DATE_TYPE = "DateType";
  public static final String BOOLEAN_TYPE = "BooleanType";
  public static final String TIMESTAMP_TYPE = "TimestampType";
  public static final String BYTE_TYPE = "ByteType";
  public static final String SHORT_TYPE = "ShortType";
  public static final String DECIMAL_TYPE = "DecimalType";
  public static final String STRING = "String";
  public static final String COLUMNAR = "columnar";

  public static final String INTEGER = "Integer";
  public static final String SHORT = "Short";
  public static final String NUMERIC = "Numeric";
  public static final String TIMESTAMP = "Timestamp";
  public static final String ARRAY = "ARRAY";
  public static final String STRUCT = "STRUCT";
  public static final String INCLUDE = "include";
  public static final String FROM = "from";
  public static final String WITH = "with";
  /**
   * FACT_UPDATE_EXTENSION.
   */
  public static final String FACT_DELETE_EXTENSION = "_delete";
  /**
   * MARKED_FOR_UPDATION
   */
  public static final String FACT_FILE_UPDATED = "update";
  /**
   * MAX_QUERY_EXECUTION_TIME
   */
  public static final int DEFAULT_MAX_QUERY_EXECUTION_TIME = 60;
  /**
   * LOADMETADATA_FILENAME
   */
  public static final String LOADMETADATA_FILENAME = "tablestatus";
  /**
   * INMEMORY_REOCRD_SIZE
   */
  public static final String DETAIL_QUERY_BATCH_SIZE = "carbon.detail.batch.size";
  public static final int DETAIL_QUERY_BATCH_SIZE_DEFAULT = 10000;
  /**
   * SPILL_OVER_DISK_PATH
   */
  public static final String SCHEMAS_MODIFIED_TIME_FILE = "modifiedTime.mdt";
  public static final String DEFAULT_INVISIBLE_DUMMY_MEASURE = "default_dummy_measure";
  /**
   * max level cache size upto which level cache will be loaded in memory
   */
  public static final String CARBON_MAX_LEVEL_CACHE_SIZE = "carbon.max.level.cache.size";
  /**
   * max level cache size default value in GB
   */
  public static final String CARBON_MAX_LEVEL_CACHE_SIZE_DEFAULT = "-1";
  /**
   * DOUBLE_VALUE_MEASURE
   */
  public static final char SUM_COUNT_VALUE_MEASURE = 'n';
  /**
   * BYTE_VALUE_MEASURE
   */
  public static final char BYTE_VALUE_MEASURE = 'c';
  /**
   * BIG_DECIMAL_MEASURE
   */
  public static final char BIG_DECIMAL_MEASURE = 'b';

  /**
   * BIG_INT_MEASURE
   */
  public static final char BIG_INT_MEASURE = 'l';

  /**
   * This determines the size of array to be processed in data load steps. one
   * for dimensions , one of ignore dictionary dimensions , one for measures.
   */
  public static final int ARRAYSIZE = 3;
  /**
   * CARBON_PREFETCH_BUFFERSIZE
   */
  public static final int CARBON_PREFETCH_BUFFERSIZE = 20000;
  /**
   * CARBON_PREFETCH_IN_MERGE
   */
  public static final boolean CARBON_PREFETCH_IN_MERGE_VALUE = false;
  /**
   * TEMPWRITEFILEEXTENSION
   */
  public static final String TEMPWRITEFILEEXTENSION = ".write";
  /**
   * ENABLE_AUTO_LOAD_MERGE
   */
  public static final String ENABLE_AUTO_LOAD_MERGE = "carbon.enable.auto.load.merge";
  /**
   * DEFAULT_ENABLE_AUTO_LOAD_MERGE
   */
  public static final String DEFAULT_ENABLE_AUTO_LOAD_MERGE = "false";

  /**
   * ZOOKEEPER_ENABLE_LOCK if this is set to true then zookeeper will be used to handle locking
   * mechanism of carbon
   */
  public static final String LOCK_TYPE = "carbon.lock.type";

  /**
   * ZOOKEEPER_ENABLE_DEFAULT the default value for zookeeper will be true for carbon
   */
  public static final String LOCK_TYPE_DEFAULT = "LOCALLOCK";

  /**
   * ZOOKEEPER_LOCATION this is the location in zookeeper file system where locks are created.
   * mechanism of carbon
   */
  public static final String ZOOKEEPER_LOCATION = "/CarbonLocks";

  /**
   * maximum dictionary chunk size that can be kept in memory while writing dictionary file
   */
  public static final String DICTIONARY_ONE_CHUNK_SIZE = "carbon.dictionary.chunk.size";

  /**
   * dictionary chunk default size
   */
  public static final String DICTIONARY_ONE_CHUNK_SIZE_DEFAULT = "10000";

  /**
   * xxhash algorithm property for hashmap
   */
  public static final String ENABLE_XXHASH = "carbon.enableXXHash";

  /**
   * xxhash algorithm property for hashmap. Default value false
   */
  public static final String ENABLE_XXHASH_DEFAULT = "true";

  /**
   * default charset to be used for reading and writing
   */
  public static final String DEFAULT_CHARSET = "UTF-8";

  /**
   * surrogate key that will be sent whenever in the dictionary chunks
   * a valid surrogate key is not found for a given dictionary value
   */
  public static final int INVALID_SURROGATE_KEY = -1;

  /**
   * surrogate key for MEMBER_DEFAULT_VAL
   */
  public static final int MEMBER_DEFAULT_VAL_SURROGATE_KEY = 1;

  public static final String INVALID_SEGMENT_ID = "-1";

  /**
   * Size of Major Compaction in MBs
   */
  public static final String MAJOR_COMPACTION_SIZE = "carbon.major.compaction.size";

  /**
   * By default size of major compaction in MBs.
   */
  public static final String DEFAULT_MAJOR_COMPACTION_SIZE = "1024";

  /**
   * This property is used to tell how many segments to be preserved from merging.
   */
  public static final java.lang.String PRESERVE_LATEST_SEGMENTS_NUMBER =
      "carbon.numberof.preserve.segments";

  /**
   * If preserve property is enabled then 2 segments will be preserved.
   */
  public static final String DEFAULT_PRESERVE_LATEST_SEGMENTS_NUMBER = "0";

  /**
   * This property will determine the loads of how many days can be compacted.
   */
  public static final java.lang.String DAYS_ALLOWED_TO_COMPACT = "carbon.allowed.compaction.days";

  /**
   * Default value of 1 day loads can be compacted
   */
  public static final String DEFAULT_DAYS_ALLOWED_TO_COMPACT = "0";

  /**
   * space reserved for writing block meta data in carbon data file
   */
  public static final String CARBON_BLOCK_META_RESERVED_SPACE =
      "carbon.block.meta.size.reserved.percentage";

  /**
   * default value for space reserved for writing block meta data in carbon data file
   */
  public static final String CARBON_BLOCK_META_RESERVED_SPACE_DEFAULT = "10";

  /**
   * property to enable min max during filter query
   */
  public static final String CARBON_QUERY_MIN_MAX_ENABLED = "carbon.enableMinMax";

  /**
   * default value to enable min or max during filter query execution
   */
  public static final String MIN_MAX_DEFAULT_VALUE = "true";

  /**
   * this variable is to enable/disable prefetch of data during merge sort while
   * reading data from sort temp files
   */
  public static final String CARBON_MERGE_SORT_PREFETCH = "carbon.merge.sort.prefetch";
  public static final String CARBON_MERGE_SORT_PREFETCH_DEFAULT = "true";

  /**
   *  default name of data base
   */
  public static final String DATABASE_DEFAULT_NAME = "default";

  // tblproperties
  public static final String COLUMN_GROUPS = "column_groups";
  public static final String DICTIONARY_EXCLUDE = "dictionary_exclude";
  public static final String DICTIONARY_INCLUDE = "dictionary_include";
  public static final String PARTITIONCLASS = "partitionclass";
  public static final String PARTITIONCOUNT = "partitioncount";
  public static final String COLUMN_PROPERTIES = "columnproperties";
  public static final String TABLE_BLOCKSIZE = "table_blocksize";

  /**
   * this variable is to enable/disable identify high cardinality during first data loading
   */
  public static final String HIGH_CARDINALITY_IDENTIFY_ENABLE =
      "high.cardinality.identify.enable";
  public static final String HIGH_CARDINALITY_IDENTIFY_ENABLE_DEFAULT = "true";

  /**
   * threshold of high cardinality
   */
  public static final String HIGH_CARDINALITY_THRESHOLD = "high.cardinality.threshold";
  public static final String HIGH_CARDINALITY_THRESHOLD_DEFAULT = "1000000";
  public static final int HIGH_CARDINALITY_THRESHOLD_MIN = 10000;

  /**
   * percentage of cardinality in row count
   */
  public static final String HIGH_CARDINALITY_IN_ROW_COUNT_PERCENTAGE =
      "high.cardinality.row.count.percentage";
  public static final String HIGH_CARDINALITY_IN_ROW_COUNT_PERCENTAGE_DEFAULT = "80";

  /**
   * 16 mb size
   */
  public static final long CARBON_16MB = 16*1024*1024;
  /**
   * 256 mb size
   */
  public static final long CARBON_256MB = 256*1024*1024;

  /**
   * SEGMENT_COMPACTED is property to indicate whether seg is compacted or not.
   */
  public static final String SEGMENT_COMPACTED = "Compacted";

  /**
   * property for number of core to load the blocks in driver
   */
  public static final String NUMBER_OF_CORE_TO_LOAD_DRIVER_SEGMENT =
      "no.of.cores.to.load.blocks.in.driver";
  /**
   * default number of cores
   */
  public static final int NUMBER_OF_CORE_TO_LOAD_DRIVER_SEGMENT_DEFAULT_VALUE = 10;

  /**
   * ZOOKEEPERLOCK TYPE
   */
  public static final String CARBON_LOCK_TYPE_ZOOKEEPER =
      "ZOOKEEPERLOCK";

  /**
   * LOCALLOCK TYPE
   */
  public static final String CARBON_LOCK_TYPE_LOCAL =
      "LOCALLOCK";

  /**
   * HDFSLOCK TYPE
   */
  public static final String CARBON_LOCK_TYPE_HDFS =
      "HDFSLOCK";

  /**
   * Invalid filter member log string
   */
  public static final String FILTER_INVALID_MEMBER = " Invalid Record(s) are present "
                                                     + "while filter evaluation. ";

  /**
   * Number of unmerged segments to be merged.
   */
  public static final String COMPACTION_SEGMENT_LEVEL_THRESHOLD =
      "carbon.compaction.level.threshold";

  /**
   * Default count for Number of segments to be merged in levels is 4,3
   */
  public static final String DEFAULT_SEGMENT_LEVEL_THRESHOLD = "4,3";

  /**
   * default location of the carbon metastore db
   */
  public static final String METASTORE_LOCATION_DEFAULT_VAL = "../carbon.metastore";

  /**
   * hive connection url
   */
  public static final String HIVE_CONNECTION_URL = "javax.jdo.option.ConnectionURL";

  /**
   * Rocord size in case of compaction.
   */
  public static final int COMPACTION_INMEMORY_RECORD_SIZE = 120000;

  /**
   * If the level 2 compaction is done in minor then new compacted segment will end with .2
   */
  public static String LEVEL2_COMPACTION_INDEX = ".2";

  /**
   * Indicates compaction
   */
  public static String COMPACTION_KEY_WORD = "COMPACTION";

  /**
   * hdfs temporary directory key
   */
  public static final String HDFS_TEMP_LOCATION = "hadoop.tmp.dir";

  /**
   * zookeeper url key
   */
  public static final String ZOOKEEPER_URL = "spark.deploy.zookeeper.url";

  /**
   * configure the minimum blocklet size eligible for blocklet distribution
   */
  public static final String CARBON_BLOCKLETDISTRIBUTION_MIN_REQUIRED_SIZE =
      "carbon.blockletdistribution.min.blocklet.size";

  /**
   * default blocklet size eligible for blocklet distribution
   */
  public static final int DEFAULT_CARBON_BLOCKLETDISTRIBUTION_MIN_REQUIRED_SIZE = 2;

  /**
   * File created in case of minor compaction request
   */
  public static String minorCompactionRequiredFile = "compactionRequired_minor";

  /**
   * File created in case of major compaction request
   */
  public static String majorCompactionRequiredFile = "compactionRequired_major";

  /**
   * @Deprecated : This property has been deprecated.
   * Property for enabling system level compaction lock.1 compaction can run at once.
   */
  public static String ENABLE_CONCURRENT_COMPACTION =
      "carbon.concurrent.compaction";

  /**
   * Default value of Property for enabling system level compaction lock.1 compaction can run
   * at once.
   */
  public static String DEFAULT_ENABLE_CONCURRENT_COMPACTION = "true";

  /**
   * Compaction system level lock folder.
   */
  public static String SYSTEM_LEVEL_COMPACTION_LOCK_FOLDER = "SystemCompactionLock";

  /**
   * to enable blocklet distribution
   */
  public static String ENABLE_BLOCKLET_DISTRIBUTION = "enable.blocklet.distribution";

  /**
   * to enable blocklet distribution default value
   */
  public static String ENABLE_BLOCKLET_DISTRIBUTION_DEFAULTVALUE = "true";

  private CarbonCommonConstants() {
  }
}


text:
package devops

// Copyright (c) Microsoft and contributors.  All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//
// See the License for the specific language governing permissions and
// limitations under the License.
//
// Code generated by Microsoft (R) AutoRest Code Generator.
// Changes may cause incorrect behavior and will be lost if the code is regenerated.

import (
	"context"
	"encoding/json"
	"github.com/Azure/go-autorest/autorest"
	"github.com/Azure/go-autorest/autorest/azure"
	"github.com/Azure/go-autorest/autorest/to"
	"github.com/Azure/go-autorest/tracing"
	"net/http"
)

// The package's fully qualified name.
const fqdn = "github.com/Azure/azure-sdk-for-go/services/preview/devops/mgmt/2019-07-01-preview/devops"

// CodeRepositoryType enumerates the values for code repository type.
type CodeRepositoryType string

const (
	// GitHub ...
	GitHub CodeRepositoryType = "gitHub"
	// VstsGit ...
	VstsGit CodeRepositoryType = "vstsGit"
)

// PossibleCodeRepositoryTypeValues returns an array of possible values for the CodeRepositoryType const type.
func PossibleCodeRepositoryTypeValues() []CodeRepositoryType {
	return []CodeRepositoryType{GitHub, VstsGit}
}

// InputDataType enumerates the values for input data type.
type InputDataType string

const (
	// InputDataTypeAuthorization ...
	InputDataTypeAuthorization InputDataType = "Authorization"
	// InputDataTypeBool ...
	InputDataTypeBool InputDataType = "Bool"
	// InputDataTypeInt ...
	InputDataTypeInt InputDataType = "Int"
	// InputDataTypeSecureString ...
	InputDataTypeSecureString InputDataType = "SecureString"
	// InputDataTypeString ...
	InputDataTypeString InputDataType = "String"
)

// PossibleInputDataTypeValues returns an array of possible values for the InputDataType const type.
func PossibleInputDataTypeValues() []InputDataType {
	return []InputDataType{InputDataTypeAuthorization, InputDataTypeBool, InputDataTypeInt, InputDataTypeSecureString, InputDataTypeString}
}

// Authorization authorization info used to access a resource (like code repository).
type Authorization struct {
	// AuthorizationType - Type of authorization.
	AuthorizationType *string `json:"authorizationType,omitempty"`
	// Parameters - Authorization parameters corresponding to the authorization type.
	Parameters map[string]*string `json:"parameters"`
}

// MarshalJSON is the custom marshaler for Authorization.
func (a Authorization) MarshalJSON() ([]byte, error) {
	objectMap := make(map[string]interface{})
	if a.AuthorizationType != nil {
		objectMap["authorizationType"] = a.AuthorizationType
	}
	if a.Parameters != nil {
		objectMap["parameters"] = a.Parameters
	}
	return json.Marshal(objectMap)
}

// BootstrapConfiguration configuration used to bootstrap a Pipeline.
type BootstrapConfiguration struct {
	// Repository - Repository containing the source code for the pipeline.
	Repository *CodeRepository `json:"repository,omitempty"`
	// Template - Template used to bootstrap the pipeline.
	Template *PipelineTemplate `json:"template,omitempty"`
}

// CloudError an error response from the Pipelines Resource Provider.
type CloudError struct {
	// Error - Details of the error from the Pipelines Resource Provider.
	Error *CloudErrorBody `json:"error,omitempty"`
}

// CloudErrorBody an error response from the Pipelines Resource Provider.
type CloudErrorBody struct {
	// Code - An identifier for the error. Codes are invariant and are intended to be consumed programmatically.
	Code *string `json:"code,omitempty"`
	// Message - A message describing the error, intended to be suitable for display in a user interface.
	Message *string `json:"message,omitempty"`
	// Target - The target of the particular error. For example, the name of the property in error or the method where the error occurred.
	Target *string `json:"target,omitempty"`
	// Details - A list of additional details about the error.
	Details *[]CloudErrorBody `json:"details,omitempty"`
}

// CodeRepository repository containing the source code for a pipeline.
type CodeRepository struct {
	// RepositoryType - Type of code repository. Possible values include: 'GitHub', 'VstsGit'
	RepositoryType CodeRepositoryType `json:"repositoryType,omitempty"`
	// ID - Unique immutable identifier of the code repository.
	ID *string `json:"id,omitempty"`
	// DefaultBranch - Default branch used to configure Continuous Integration (CI) in the pipeline.
	DefaultBranch *string `json:"defaultBranch,omitempty"`
	// Authorization - Authorization info to access the code repository.
	Authorization *Authorization `json:"authorization,omitempty"`
	// Properties - Repository-specific properties.
	Properties map[string]*string `json:"properties"`
}

// MarshalJSON is the custom marshaler for CodeRepository.
func (cr CodeRepository) MarshalJSON() ([]byte, error) {
	objectMap := make(map[string]interface{})
	if cr.RepositoryType != "" {
		objectMap["repositoryType"] = cr.RepositoryType
	}
	if cr.ID != nil {
		objectMap["id"] = cr.ID
	}
	if cr.DefaultBranch != nil {
		objectMap["defaultBranch"] = cr.DefaultBranch
	}
	if cr.Authorization != nil {
		objectMap["authorization"] = cr.Authorization
	}
	if cr.Properties != nil {
		objectMap["properties"] = cr.Properties
	}
	return json.Marshal(objectMap)
}

// InputDescriptor representation of a pipeline template input parameter.
type InputDescriptor struct {
	// ID - Identifier of the input parameter.
	ID *string `json:"id,omitempty"`
	// Description - Description of the input parameter.
	Description *string `json:"description,omitempty"`
	// Type - Data type of the value of the input parameter. Possible values include: 'InputDataTypeString', 'InputDataTypeSecureString', 'InputDataTypeInt', 'InputDataTypeBool', 'InputDataTypeAuthorization'
	Type InputDataType `json:"type,omitempty"`
	// PossibleValues - List of possible values for the input parameter.
	PossibleValues *[]InputValue `json:"possibleValues,omitempty"`
}

// InputValue representation of a pipeline template input parameter value.
type InputValue struct {
	// Value - Value of an input parameter.
	Value *string `json:"value,omitempty"`
	// DisplayValue - Description of the input parameter value.
	DisplayValue *string `json:"displayValue,omitempty"`
}

// Operation properties of an Operation.
type Operation struct {
	// Name - READ-ONLY; Name of the operation.
	Name *string `json:"name,omitempty"`
	// IsDataAction - Indicates whether the operation applies to data-plane.
	IsDataAction *string `json:"isDataAction,omitempty"`
	// OperationDisplayValue - Display information of the operation.
	*OperationDisplayValue `json:"display,omitempty"`
}

// MarshalJSON is the custom marshaler for Operation.
func (o Operation) MarshalJSON() ([]byte, error) {
	objectMap := make(map[string]interface{})
	if o.IsDataAction != nil {
		objectMap["isDataAction"] = o.IsDataAction
	}
	if o.OperationDisplayValue != nil {
		objectMap["display"] = o.OperationDisplayValue
	}
	return json.Marshal(objectMap)
}

// UnmarshalJSON is the custom unmarshaler for Operation struct.
func (o *Operation) UnmarshalJSON(body []byte) error {
	var m map[string]*json.RawMessage
	err := json.Unmarshal(body, &m)
	if err != nil {
		return err
	}
	for k, v := range m {
		switch k {
		case "name":
			if v != nil {
				var name string
				err = json.Unmarshal(*v, &name)
				if err != nil {
					return err
				}
				o.Name = &name
			}
		case "isDataAction":
			if v != nil {
				var isDataAction string
				err = json.Unmarshal(*v, &isDataAction)
				if err != nil {
					return err
				}
				o.IsDataAction = &isDataAction
			}
		case "display":
			if v != nil {
				var operationDisplayValue OperationDisplayValue
				err = json.Unmarshal(*v, &operationDisplayValue)
				if err != nil {
					return err
				}
				o.OperationDisplayValue = &operationDisplayValue
			}
		}
	}

	return nil
}

// OperationDisplayValue display information of an operation.
type OperationDisplayValue struct {
	// Operation - READ-ONLY; Friendly name of the operation.
	Operation *string `json:"operation,omitempty"`
	// Resource - READ-ONLY; Friendly name of the resource type the operation applies to.
	Resource *string `json:"resource,omitempty"`
	// Description - READ-ONLY; Friendly description of the operation.
	Description *string `json:"description,omitempty"`
	// Provider - READ-ONLY; Friendly name of the resource provider.
	Provider *string `json:"provider,omitempty"`
}

// OperationListResult result of a request to list all operations supported by Microsoft.DevOps resource
// provider.
type OperationListResult struct {
	autorest.Response `json:"-"`
	// Value - READ-ONLY; List of operations supported by Microsoft.DevOps resource provider.
	Value *[]Operation `json:"value,omitempty"`
	// NextLink - The URL to get the next set of operations, if there are any.
	NextLink *string `json:"nextLink,omitempty"`
}

// OperationListResultIterator provides access to a complete listing of Operation values.
type OperationListResultIterator struct {
	i    int
	page OperationListResultPage
}

// NextWithContext advances to the next value.  If there was an error making
// the request the iterator does not advance and the error is returned.
func (iter *OperationListResultIterator) NextWithContext(ctx context.Context) (err error) {
	if tracing.IsEnabled() {
		ctx = tracing.StartSpan(ctx, fqdn+"/OperationListResultIterator.NextWithContext")
		defer func() {
			sc := -1
			if iter.Response().Response.Response != nil {
				sc = iter.Response().Response.Response.StatusCode
			}
			tracing.EndSpan(ctx, sc, err)
		}()
	}
	iter.i++
	if iter.i < len(iter.page.Values()) {
		return nil
	}
	err = iter.page.NextWithContext(ctx)
	if err != nil {
		iter.i--
		return err
	}
	iter.i = 0
	return nil
}

// Next advances to the next value.  If there was an error making
// the request the iterator does not advance and the error is returned.
// Deprecated: Use NextWithContext() instead.
func (iter *OperationListResultIterator) Next() error {
	return iter.NextWithContext(context.Background())
}

// NotDone returns true if the enumeration should be started or is not yet complete.
func (iter OperationListResultIterator) NotDone() bool {
	return iter.page.NotDone() && iter.i < len(iter.page.Values())
}

// Response returns the raw server response from the last page request.
func (iter OperationListResultIterator) Response() OperationListResult {
	return iter.page.Response()
}

// Value returns the current value or a zero-initialized value if the
// iterator has advanced beyond the end of the collection.
func (iter OperationListResultIterator) Value() Operation {
	if !iter.page.NotDone() {
		return Operation{}
	}
	return iter.page.Values()[iter.i]
}

// Creates a new instance of the OperationListResultIterator type.
func NewOperationListResultIterator(page OperationListResultPage) OperationListResultIterator {
	return OperationListResultIterator{page: page}
}

// IsEmpty returns true if the ListResult contains no values.
func (olr OperationListResult) IsEmpty() bool {
	return olr.Value == nil || len(*olr.Value) == 0
}

// operationListResultPreparer prepares a request to retrieve the next set of results.
// It returns nil if no more results exist.
func (olr OperationListResult) operationListResultPreparer(ctx context.Context) (*http.Request, error) {
	if olr.NextLink == nil || len(to.String(olr.NextLink)) < 1 {
		return nil, nil
	}
	return autorest.Prepare((&http.Request{}).WithContext(ctx),
		autorest.AsJSON(),
		autorest.AsGet(),
		autorest.WithBaseURL(to.String(olr.NextLink)))
}

// OperationListResultPage contains a page of Operation values.
type OperationListResultPage struct {
	fn  func(context.Context, OperationListResult) (OperationListResult, error)
	olr OperationListResult
}

// NextWithContext advances to the next page of values.  If there was an error making
// the request the page does not advance and the error is returned.
func (page *OperationListResultPage) NextWithContext(ctx context.Context) (err error) {
	if tracing.IsEnabled() {
		ctx = tracing.StartSpan(ctx, fqdn+"/OperationListResultPage.NextWithContext")
		defer func() {
			sc := -1
			if page.Response().Response.Response != nil {
				sc = page.Response().Response.Response.StatusCode
			}
			tracing.EndSpan(ctx, sc, err)
		}()
	}
	next, err := page.fn(ctx, page.olr)
	if err != nil {
		return err
	}
	page.olr = next
	return nil
}

// Next advances to the next page of values.  If there was an error making
// the request the page does not advance and the error is returned.
// Deprecated: Use NextWithContext() instead.
func (page *OperationListResultPage) Next() error {
	return page.NextWithContext(context.Background())
}

// NotDone returns true if the page enumeration should be started or is not yet complete.
func (page OperationListResultPage) NotDone() bool {
	return !page.olr.IsEmpty()
}

// Response returns the raw server response from the last page request.
func (page OperationListResultPage) Response() OperationListResult {
	return page.olr
}

// Values returns the slice of values for the current page or nil if there are no values.
func (page OperationListResultPage) Values() []Operation {
	if page.olr.IsEmpty() {
		return nil
	}
	return *page.olr.Value
}

// Creates a new instance of the OperationListResultPage type.
func NewOperationListResultPage(getNextPage func(context.Context, OperationListResult) (OperationListResult, error)) OperationListResultPage {
	return OperationListResultPage{fn: getNextPage}
}

// OrganizationReference reference to an Azure DevOps Organization.
type OrganizationReference struct {
	// ID - READ-ONLY; Unique immutable identifier for the Azure DevOps Organization.
	ID *string `json:"id,omitempty"`
	// Name - Name of the Azure DevOps Organization.
	Name *string `json:"name,omitempty"`
}

// Pipeline azure DevOps Pipeline used to configure Continuous Integration (CI) & Continuous Delivery (CD)
// for Azure resources.
type Pipeline struct {
	autorest.Response `json:"-"`
	// PipelineProperties - Custom properties of the Pipeline.
	*PipelineProperties `json:"properties,omitempty"`
	// ID - READ-ONLY; Resource Id
	ID *string `json:"id,omitempty"`
	// Type - READ-ONLY; Resource Type
	Type *string `json:"type,omitempty"`
	// Tags - Resource Tags
	Tags map[string]*string `json:"tags"`
	// Location - Resource Location
	Location *string `json:"location,omitempty"`
	// Name - READ-ONLY; Resource Name
	Name *string `json:"name,omitempty"`
}

// MarshalJSON is the custom marshaler for Pipeline.
func (p Pipeline) MarshalJSON() ([]byte, error) {
	objectMap := make(map[string]interface{})
	if p.PipelineProperties != nil {
		objectMap["properties"] = p.PipelineProperties
	}
	if p.Tags != nil {
		objectMap["tags"] = p.Tags
	}
	if p.Location != nil {
		objectMap["location"] = p.Location
	}
	return json.Marshal(objectMap)
}

// UnmarshalJSON is the custom unmarshaler for Pipeline struct.
func (p *Pipeline) UnmarshalJSON(body []byte) error {
	var m map[string]*json.RawMessage
	err := json.Unmarshal(body, &m)
	if err != nil {
		return err
	}
	for k, v := range m {
		switch k {
		case "properties":
			if v != nil {
				var pipelineProperties PipelineProperties
				err = json.Unmarshal(*v, &pipelineProperties)
				if err != nil {
					return err
				}
				p.PipelineProperties = &pipelineProperties
			}
		case "id":
			if v != nil {
				var ID string
				err = json.Unmarshal(*v, &ID)
				if err != nil {
					return err
				}
				p.ID = &ID
			}
		case "type":
			if v != nil {
				var typeVar string
				err = json.Unmarshal(*v, &typeVar)
				if err != nil {
					return err
				}
				p.Type = &typeVar
			}
		case "tags":
			if v != nil {
				var tags map[string]*string
				err = json.Unmarshal(*v, &tags)
				if err != nil {
					return err
				}
				p.Tags = tags
			}
		case "location":
			if v != nil {
				var location string
				err = json.Unmarshal(*v, &location)
				if err != nil {
					return err
				}
				p.Location = &location
			}
		case "name":
			if v != nil {
				var name string
				err = json.Unmarshal(*v, &name)
				if err != nil {
					return err
				}
				p.Name = &name
			}
		}
	}

	return nil
}

// PipelineListResult result of a request to list all Azure Pipelines under a given scope.
type PipelineListResult struct {
	autorest.Response `json:"-"`
	// Value - List of pipelines.
	Value *[]Pipeline `json:"value,omitempty"`
	// NextLink - URL to get the next set of Pipelines, if there are any.
	NextLink *string `json:"nextLink,omitempty"`
}

// PipelineListResultIterator provides access to a complete listing of Pipeline values.
type PipelineListResultIterator struct {
	i    int
	page PipelineListResultPage
}

// NextWithContext advances to the next value.  If there was an error making
// the request the iterator does not advance and the error is returned.
func (iter *PipelineListResultIterator) NextWithContext(ctx context.Context) (err error) {
	if tracing.IsEnabled() {
		ctx = tracing.StartSpan(ctx, fqdn+"/PipelineListResultIterator.NextWithContext")
		defer func() {
			sc := -1
			if iter.Response().Response.Response != nil {
				sc = iter.Response().Response.Response.StatusCode
			}
			tracing.EndSpan(ctx, sc, err)
		}()
	}
	iter.i++
	if iter.i < len(iter.page.Values()) {
		return nil
	}
	err = iter.page.NextWithContext(ctx)
	if err != nil {
		iter.i--
		return err
	}
	iter.i = 0
	return nil
}

// Next advances to the next value.  If there was an error making
// the request the iterator does not advance and the error is returned.
// Deprecated: Use NextWithContext() instead.
func (iter *PipelineListResultIterator) Next() error {
	return iter.NextWithContext(context.Background())
}

// NotDone returns true if the enumeration should be started or is not yet complete.
func (iter PipelineListResultIterator) NotDone() bool {
	return iter.page.NotDone() && iter.i < len(iter.page.Values())
}

// Response returns the raw server response from the last page request.
func (iter PipelineListResultIterator) Response() PipelineListResult {
	return iter.page.Response()
}

// Value returns the current value or a zero-initialized value if the
// iterator has advanced beyond the end of the collection.
func (iter PipelineListResultIterator) Value() Pipeline {
	if !iter.page.NotDone() {
		return Pipeline{}
	}
	return iter.page.Values()[iter.i]
}

// Creates a new instance of the PipelineListResultIterator type.
func NewPipelineListResultIterator(page PipelineListResultPage) PipelineListResultIterator {
	return PipelineListResultIterator{page: page}
}

// IsEmpty returns true if the ListResult contains no values.
func (plr PipelineListResult) IsEmpty() bool {
	return plr.Value == nil || len(*plr.Value) == 0
}

// pipelineListResultPreparer prepares a request to retrieve the next set of results.
// It returns nil if no more results exist.
func (plr PipelineListResult) pipelineListResultPreparer(ctx context.Context) (*http.Request, error) {
	if plr.NextLink == nil || len(to.String(plr.NextLink)) < 1 {
		return nil, nil
	}
	return autorest.Prepare((&http.Request{}).WithContext(ctx),
		autorest.AsJSON(),
		autorest.AsGet(),
		autorest.WithBaseURL(to.String(plr.NextLink)))
}

// PipelineListResultPage contains a page of Pipeline values.
type PipelineListResultPage struct {
	fn  func(context.Context, PipelineListResult) (PipelineListResult, error)
	plr PipelineListResult
}

// NextWithContext advances to the next page of values.  If there was an error making
// the request the page does not advance and the error is returned.
func (page *PipelineListResultPage) NextWithContext(ctx context.Context) (err error) {
	if tracing.IsEnabled() {
		ctx = tracing.StartSpan(ctx, fqdn+"/PipelineListResultPage.NextWithContext")
		defer func() {
			sc := -1
			if page.Response().Response.Response != nil {
				sc = page.Response().Response.Response.StatusCode
			}
			tracing.EndSpan(ctx, sc, err)
		}()
	}
	next, err := page.fn(ctx, page.plr)
	if err != nil {
		return err
	}
	page.plr = next
	return nil
}

// Next advances to the next page of values.  If there was an error making
// the request the page does not advance and the error is returned.
// Deprecated: Use NextWithContext() instead.
func (page *PipelineListResultPage) Next() error {
	return page.NextWithContext(context.Background())
}

// NotDone returns true if the page enumeration should be started or is not yet complete.
func (page PipelineListResultPage) NotDone() bool {
	return !page.plr.IsEmpty()
}

// Response returns the raw server response from the last page request.
func (page PipelineListResultPage) Response() PipelineListResult {
	return page.plr
}

// Values returns the slice of values for the current page or nil if there are no values.
func (page PipelineListResultPage) Values() []Pipeline {
	if page.plr.IsEmpty() {
		return nil
	}
	return *page.plr.Value
}

// Creates a new instance of the PipelineListResultPage type.
func NewPipelineListResultPage(getNextPage func(context.Context, PipelineListResult) (PipelineListResult, error)) PipelineListResultPage {
	return PipelineListResultPage{fn: getNextPage}
}

// PipelineProperties custom properties of a Pipeline.
type PipelineProperties struct {
	// PipelineID - READ-ONLY; Unique identifier of the Azure Pipeline within the Azure DevOps Project.
	PipelineID *int32 `json:"pipelineId,omitempty"`
	// Organization - Reference to the Azure DevOps Organization containing the Pipeline.
	Organization *OrganizationReference `json:"organization,omitempty"`
	// Project - Reference to the Azure DevOps Project containing the Pipeline.
	Project *ProjectReference `json:"project,omitempty"`
	// BootstrapConfiguration - Configuration used to bootstrap the Pipeline.
	BootstrapConfiguration *BootstrapConfiguration `json:"bootstrapConfiguration,omitempty"`
}

// PipelinesCreateOrUpdateFuture an abstraction for monitoring and retrieving the results of a long-running
// operation.
type PipelinesCreateOrUpdateFuture struct {
	azure.Future
}

// Result returns the result of the asynchronous operation.
// If the operation has not completed it will return an error.
func (future *PipelinesCreateOrUpdateFuture) Result(client PipelinesClient) (p Pipeline, err error) {
	var done bool
	done, err = future.DoneWithContext(context.Background(), client)
	if err != nil {
		err = autorest.NewErrorWithError(err, "devops.PipelinesCreateOrUpdateFuture", "Result", future.Response(), "Polling failure")
		return
	}
	if !done {
		err = azure.NewAsyncOpIncompleteError("devops.PipelinesCreateOrUpdateFuture")
		return
	}
	sender := autorest.DecorateSender(client, autorest.DoRetryForStatusCodes(client.RetryAttempts, client.RetryDuration, autorest.StatusCodesForRetry...))
	if p.Response.Response, err = future.GetResult(sender); err == nil && p.Response.Response.StatusCode != http.StatusNoContent {
		p, err = client.CreateOrUpdateResponder(p.Response.Response)
		if err != nil {
			err = autorest.NewErrorWithError(err, "devops.PipelinesCreateOrUpdateFuture", "Result", p.Response.Response, "Failure responding to request")
		}
	}
	return
}

// PipelineTemplate template used to bootstrap the pipeline.
type PipelineTemplate struct {
	// ID - Unique identifier of the pipeline template.
	ID *string `json:"id,omitempty"`
	// Parameters - Dictionary of input parameters used in the pipeline template.
	Parameters map[string]*string `json:"parameters"`
}

// MarshalJSON is the custom marshaler for PipelineTemplate.
func (pt PipelineTemplate) MarshalJSON() ([]byte, error) {
	objectMap := make(map[string]interface{})
	if pt.ID != nil {
		objectMap["id"] = pt.ID
	}
	if pt.Parameters != nil {
		objectMap["parameters"] = pt.Parameters
	}
	return json.Marshal(objectMap)
}

// PipelineTemplateDefinition definition of a pipeline template.
type PipelineTemplateDefinition struct {
	// ID - Unique identifier of the pipeline template.
	ID *string `json:"id,omitempty"`
	// Description - Description of the pipeline enabled by the template.
	Description *string `json:"description,omitempty"`
	// Inputs - List of input parameters required by the template to create a pipeline.
	Inputs *[]InputDescriptor `json:"inputs,omitempty"`
}

// PipelineTemplateDefinitionListResult result of a request to list all pipeline template definitions.
type PipelineTemplateDefinitionListResult struct {
	autorest.Response `json:"-"`
	// Value - List of pipeline template definitions.
	Value *[]PipelineTemplateDefinition `json:"value,omitempty"`
	// NextLink - The URL to get the next set of pipeline template definitions, if there are any.
	NextLink *string `json:"nextLink,omitempty"`
}

// PipelineTemplateDefinitionListResultIterator provides access to a complete listing of
// PipelineTemplateDefinition values.
type PipelineTemplateDefinitionListResultIterator struct {
	i    int
	page PipelineTemplateDefinitionListResultPage
}

// NextWithContext advances to the next value.  If there was an error making
// the request the iterator does not advance and the error is returned.
func (iter *PipelineTemplateDefinitionListResultIterator) NextWithContext(ctx context.Context) (err error) {
	if tracing.IsEnabled() {
		ctx = tracing.StartSpan(ctx, fqdn+"/PipelineTemplateDefinitionListResultIterator.NextWithContext")
		defer func() {
			sc := -1
			if iter.Response().Response.Response != nil {
				sc = iter.Response().Response.Response.StatusCode
			}
			tracing.EndSpan(ctx, sc, err)
		}()
	}
	iter.i++
	if iter.i < len(iter.page.Values()) {
		return nil
	}
	err = iter.page.NextWithContext(ctx)
	if err != nil {
		iter.i--
		return err
	}
	iter.i = 0
	return nil
}

// Next advances to the next value.  If there was an error making
// the request the iterator does not advance and the error is returned.
// Deprecated: Use NextWithContext() instead.
func (iter *PipelineTemplateDefinitionListResultIterator) Next() error {
	return iter.NextWithContext(context.Background())
}

// NotDone returns true if the enumeration should be started or is not yet complete.
func (iter PipelineTemplateDefinitionListResultIterator) NotDone() bool {
	return iter.page.NotDone() && iter.i < len(iter.page.Values())
}

// Response returns the raw server response from the last page request.
func (iter PipelineTemplateDefinitionListResultIterator) Response() PipelineTemplateDefinitionListResult {
	return iter.page.Response()
}

// Value returns the current value or a zero-initialized value if the
// iterator has advanced beyond the end of the collection.
func (iter PipelineTemplateDefinitionListResultIterator) Value() PipelineTemplateDefinition {
	if !iter.page.NotDone() {
		return PipelineTemplateDefinition{}
	}
	return iter.page.Values()[iter.i]
}

// Creates a new instance of the PipelineTemplateDefinitionListResultIterator type.
func NewPipelineTemplateDefinitionListResultIterator(page PipelineTemplateDefinitionListResultPage) PipelineTemplateDefinitionListResultIterator {
	return PipelineTemplateDefinitionListResultIterator{page: page}
}

// IsEmpty returns true if the ListResult contains no values.
func (ptdlr PipelineTemplateDefinitionListResult) IsEmpty() bool {
	return ptdlr.Value == nil || len(*ptdlr.Value) == 0
}

// pipelineTemplateDefinitionListResultPreparer prepares a request to retrieve the next set of results.
// It returns nil if no more results exist.
func (ptdlr PipelineTemplateDefinitionListResult) pipelineTemplateDefinitionListResultPreparer(ctx context.Context) (*http.Request, error) {
	if ptdlr.NextLink == nil || len(to.String(ptdlr.NextLink)) < 1 {
		return nil, nil
	}
	return autorest.Prepare((&http.Request{}).WithContext(ctx),
		autorest.AsJSON(),
		autorest.AsGet(),
		autorest.WithBaseURL(to.String(ptdlr.NextLink)))
}

// PipelineTemplateDefinitionListResultPage contains a page of PipelineTemplateDefinition values.
type PipelineTemplateDefinitionListResultPage struct {
	fn    func(context.Context, PipelineTemplateDefinitionListResult) (PipelineTemplateDefinitionListResult, error)
	ptdlr PipelineTemplateDefinitionListResult
}

// NextWithContext advances to the next page of values.  If there was an error making
// the request the page does not advance and the error is returned.
func (page *PipelineTemplateDefinitionListResultPage) NextWithContext(ctx context.Context) (err error) {
	if tracing.IsEnabled() {
		ctx = tracing.StartSpan(ctx, fqdn+"/PipelineTemplateDefinitionListResultPage.NextWithContext")
		defer func() {
			sc := -1
			if page.Response().Response.Response != nil {
				sc = page.Response().Response.Response.StatusCode
			}
			tracing.EndSpan(ctx, sc, err)
		}()
	}
	next, err := page.fn(ctx, page.ptdlr)
	if err != nil {
		return err
	}
	page.ptdlr = next
	return nil
}

// Next advances to the next page of values.  If there was an error making
// the request the page does not advance and the error is returned.
// Deprecated: Use NextWithContext() instead.
func (page *PipelineTemplateDefinitionListResultPage) Next() error {
	return page.NextWithContext(context.Background())
}

// NotDone returns true if the page enumeration should be started or is not yet complete.
func (page PipelineTemplateDefinitionListResultPage) NotDone() bool {
	return !page.ptdlr.IsEmpty()
}

// Response returns the raw server response from the last page request.
func (page PipelineTemplateDefinitionListResultPage) Response() PipelineTemplateDefinitionListResult {
	return page.ptdlr
}

// Values returns the slice of values for the current page or nil if there are no values.
func (page PipelineTemplateDefinitionListResultPage) Values() []PipelineTemplateDefinition {
	if page.ptdlr.IsEmpty() {
		return nil
	}
	return *page.ptdlr.Value
}

// Creates a new instance of the PipelineTemplateDefinitionListResultPage type.
func NewPipelineTemplateDefinitionListResultPage(getNextPage func(context.Context, PipelineTemplateDefinitionListResult) (PipelineTemplateDefinitionListResult, error)) PipelineTemplateDefinitionListResultPage {
	return PipelineTemplateDefinitionListResultPage{fn: getNextPage}
}

// PipelineUpdateParameters request payload used to update an existing Azure Pipeline.
type PipelineUpdateParameters struct {
	// Tags - Dictionary of key-value pairs to be set as tags on the Azure Pipeline. This will overwrite any existing tags.
	Tags map[string]*string `json:"tags"`
}

// MarshalJSON is the custom marshaler for PipelineUpdateParameters.
func (pup PipelineUpdateParameters) MarshalJSON() ([]byte, error) {
	objectMap := make(map[string]interface{})
	if pup.Tags != nil {
		objectMap["tags"] = pup.Tags
	}
	return json.Marshal(objectMap)
}

// ProjectReference reference to an Azure DevOps Project.
type ProjectReference struct {
	// ID - READ-ONLY; Unique immutable identifier of the Azure DevOps Project.
	ID *string `json:"id,omitempty"`
	// Name - Name of the Azure DevOps Project.
	Name *string `json:"name,omitempty"`
}

// Resource an Azure Resource Manager (ARM) resource.
type Resource struct {
	// ID - READ-ONLY; Resource Id
	ID *string `json:"id,omitempty"`
	// Type - READ-ONLY; Resource Type
	Type *string `json:"type,omitempty"`
	// Tags - Resource Tags
	Tags map[string]*string `json:"tags"`
	// Location - Resource Location
	Location *string `json:"location,omitempty"`
	// Name - READ-ONLY; Resource Name
	Name *string `json:"name,omitempty"`
}

// MarshalJSON is the custom marshaler for Resource.
func (r Resource) MarshalJSON() ([]byte, error) {
	objectMap := make(map[string]interface{})
	if r.Tags != nil {
		objectMap["tags"] = r.Tags
	}
	if r.Location != nil {
		objectMap["location"] = r.Location
	}
	return json.Marshal(objectMap)
}


text:
package org.apache.flink.table.runtime.operators.python;

import org.apache.flink.python.PythonFunctionRunner;
import org.apache.flink.streaming.util.TestHarnessUtil;
import org.apache.flink.table.functions.python.PythonFunctionInfo;
import org.apache.flink.table.runtime.types.CRow;
import org.apache.flink.table.types.logical.RowType;
import org.apache.flink.types.Row;

import org.apache.beam.sdk.fn.data.FnDataReceiver;

import java.util.Collection;
import java.util.Queue;

/**
 * Tests for {@link PythonScalarFunctionOperator}.
 */
public class PythonScalarFunctionOperatorTest extends PythonScalarFunctionOperatorTestBase<CRow, CRow, Row, Row> {

	@Override
	public AbstractPythonScalarFunctionOperator<CRow, CRow, Row, Row> getTestOperator(
		PythonFunctionInfo[] scalarFunctions,
		RowType inputType,
		RowType outputType,
		int[] udfInputOffsets,
		int[] forwardedFields) {
		return new PassThroughPythonScalarFunctionOperator(
			scalarFunctions, inputType, outputType, udfInputOffsets, forwardedFields);
	}

	@Override
	public CRow newRow(boolean accumulateMsg, Object... fields) {
		return new CRow(Row.of(fields), accumulateMsg);
	}

	@Override
	public void assertOutputEquals(String message, Collection<Object> expected, Collection<Object> actual) {
		TestHarnessUtil.assertOutputEquals(message, (Queue<Object>) expected, (Queue<Object>) actual);
	}

	private static class PassThroughPythonScalarFunctionOperator extends PythonScalarFunctionOperator {

		PassThroughPythonScalarFunctionOperator(
			PythonFunctionInfo[] scalarFunctions,
			RowType inputType,
			RowType outputType,
			int[] udfInputOffsets,
			int[] forwardedFields) {
			super(scalarFunctions, inputType, outputType, udfInputOffsets, forwardedFields);
		}

		@Override
		public PythonFunctionRunner<Row> createPythonFunctionRunner(
			FnDataReceiver<Row> resultReceiver) {
			return new PassThroughPythonFunctionRunner<Row>(resultReceiver) {
				@Override
				public Row copy(Row element) {
					return Row.copy(element);
				}
			};
		}
	}
}


text:
import pytest

from thinglang import pipeline
from thinglang.compiler.errors import TargetNotCallable, NoMatchingOverload
from thinglang.lexer.values.identifier import Identifier
from thinglang.lexer.values.inline_text import InlineString
from thinglang.lexer.values.numeric import NumericValue
from thinglang.utils.source_context import SourceContext

BASE = """
thing Program
    has number member1
    setup
        {code}

    does no_args
        1 + 1

    does two_args with number a, text b
        1 + 1
"""

def test_method_call_on_non_method_target():
    with pytest.raises(TargetNotCallable):
        pipeline.compile(SourceContext.wrap(BASE.format(code="self.member1()")))

def test_argument_count_mismatch():
    with pytest.raises(NoMatchingOverload) as e:
        pipeline.compile(SourceContext.wrap(BASE.format(code="self.no_args(1)")))

    assert e.value.methods[0].name == Identifier('no_args') and e.value.arguments == [NumericValue(1)]

    with pytest.raises(NoMatchingOverload) as e:
        pipeline.compile(SourceContext.wrap(BASE.format(code="self.two_args(1)")))

    assert e.value.methods[0].name == Identifier('two_args') and e.value.arguments == [NumericValue(1)]

def test_argument_type_mismatch():
    with pytest.raises(NoMatchingOverload) as e:
        pipeline.compile(SourceContext.wrap(BASE.format(code='self.two_args("hello", 3)')))

    assert e.value.methods[0].name == Identifier('two_args') and e.value.arguments == [InlineString("hello"), NumericValue(3)]

    pipeline.compile(SourceContext.wrap(BASE.format(code='self.two_args(3, 3)')))  # Can be implicitly casted


text:
{% include header.html %}

            {{ content }}

          {% include sidebar.html %}

  {% include footer.html %}


text:
import { BaseVector } from './base';
import { RowProxyGenerator } from './row';
import { DataType, Struct } from '../type';
export declare class StructVector<T extends {
    [key: string]: DataType;
} = any> extends BaseVector<Struct<T>> {
    asMap(keysSorted?: boolean): import("./map").MapVector<T>;
    private _rowProxy;
    readonly rowProxy: RowProxyGenerator<T>;
}


text:
package org.apache.maven.plugin.dependency.utils.filters;

import org.apache.maven.plugin.MojoExecutionException;
import org.apache.maven.plugin.dependency.fromConfiguration.ArtifactItem;
import org.apache.maven.plugin.dependency.utils.markers.MarkerHandler;
import org.apache.maven.shared.artifact.filter.collection.ArtifactFilterException;

/**
 * @author Brian Fox
 * @version $Id$
 */
public class ResolveFileFilter
    extends MarkerFileFilter
{

    public ResolveFileFilter( MarkerHandler handler )
    {
        super( true, true, true, handler );
    }

    public boolean isArtifactIncluded( ArtifactItem item )
        throws ArtifactFilterException
    {
        handler.setArtifact( item.getArtifact() );
        try
        {
            return ( !handler.isMarkerSet() );
        }
        catch ( MojoExecutionException e )
        {
            throw new ArtifactFilterException( e.getMessage(), e );
        }
    }
}


text:
<?php
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: google/cloud/networksecurity/v1beta1/authorization_policy.proto

namespace Google\Cloud\NetworkSecurity\V1beta1\AuthorizationPolicy;

use UnexpectedValueException;

/**
 * Possible values that define what action to take.
 *
 * Protobuf type google.cloud.networksecurity.v1beta1.AuthorizationPolicy.Action
 */
class Action
{
    /**
     * Default value.
     *
     * Generated from protobuf enum ACTION_UNSPECIFIED = 0;
     */
    const ACTION_UNSPECIFIED = 0;
    /**
     * Grant access.
     *
     * Generated from protobuf enum ALLOW = 1;
     */
    const ALLOW = 1;
    /**
     * Deny access.
     *
     * Generated from protobuf enum DENY = 2;
     */
    const DENY = 2;

    private static $valueToName = [
        self::ACTION_UNSPECIFIED => 'ACTION_UNSPECIFIED',
        self::ALLOW => 'ALLOW',
        self::DENY => 'DENY',
    ];

    public static function name($value)
    {
        if (!isset(self::$valueToName[$value])) {
            throw new UnexpectedValueException(sprintf(
                    'Enum %s has no name defined for value %s', __CLASS__, $value));
        }
        return self::$valueToName[$value];
    }

    public static function value($name)
    {
        $const = __CLASS__ . '::' . strtoupper($name);
        if (!defined($const)) {
            throw new UnexpectedValueException(sprintf(
                    'Enum %s has no value defined for name %s', __CLASS__, $name));
        }
        return constant($const);
    }
}