text:
namespace net {

class AddressList;
class IPEndPoint;
class SpdySession;
class SSLCertRequestInfo;
class SSLInfo;

// The SpdyStream is used by the SpdySession to represent each stream known
// on the SpdySession.  This class provides interfaces for SpdySession to use.
// Streams can be created either by the client or by the server.  When they
// are initiated by the client, both the SpdySession and client object (such as
// a SpdyNetworkTransaction) will maintain a reference to the stream.  When
// initiated by the server, only the SpdySession will maintain any reference,
// until such a time as a client object requests a stream for the path.
class NET_EXPORT_PRIVATE SpdyStream
    : public base::RefCounted<SpdyStream>,
      public ChunkCallback {
 public:
  // Delegate handles protocol specific behavior of spdy stream.
  class NET_EXPORT_PRIVATE Delegate {
   public:
    Delegate() {}

    // Called when SYN frame has been sent.
    // Returns true if no more data to be sent after SYN frame.
    virtual bool OnSendHeadersComplete(int status) = 0;

    // Called when stream is ready to send data.
    // Returns network error code. OK when it successfully sent data.
    virtual int OnSendBody() = 0;

    // Called when data has been sent. |status| indicates network error
    // or number of bytes that has been sent. On return, |eof| is set to true
    // if no more data is available to send in the request body.
    // Returns network error code. OK when it successfully sent data.
    virtual int OnSendBodyComplete(int status, bool* eof) = 0;

    // Called when the SYN_STREAM, SYN_REPLY, or HEADERS frames are received.
    // Normal streams will receive a SYN_REPLY and optional HEADERS frames.
    // Pushed streams will receive a SYN_STREAM and optional HEADERS frames.
    // Because a stream may have a SYN_* frame and multiple HEADERS frames,
    // this callback may be called multiple times.
    // |status| indicates network error. Returns network error code.
    virtual int OnResponseReceived(const SpdyHeaderBlock& response,
                                   base::Time response_time,
                                   int status) = 0;

    // Called when data is received.
    virtual void OnDataReceived(const char* data, int length) = 0;

    // Called when data is sent.
    virtual void OnDataSent(int length) = 0;

    // Called when SpdyStream is closed.
    virtual void OnClose(int status) = 0;

    // Sets the callback to be invoked when a new chunk is available to upload.
    virtual void set_chunk_callback(ChunkCallback* callback) = 0;

   protected:
    friend class base::RefCounted<Delegate>;
    virtual ~Delegate() {}

   private:
    DISALLOW_COPY_AND_ASSIGN(Delegate);
  };

  // SpdyStream constructor
  SpdyStream(SpdySession* session,
             SpdyStreamId stream_id,
             bool pushed,
             const BoundNetLog& net_log);

  // Set new |delegate|. |delegate| must not be NULL.
  // If it already received SYN_REPLY or data, OnResponseReceived() or
  // OnDataReceived() will be called.
  void SetDelegate(Delegate* delegate);
  Delegate* GetDelegate() { return delegate_; }

  // Detach delegate from the stream. It will cancel the stream if it was not
  // cancelled yet.  It is safe to call multiple times.
  void DetachDelegate();

  // Is this stream a pushed stream from the server.
  bool pushed() const { return pushed_; }

  SpdyStreamId stream_id() const { return stream_id_; }
  void set_stream_id(SpdyStreamId stream_id) { stream_id_ = stream_id; }

  bool response_received() const { return response_received_; }
  void set_response_received() { response_received_ = true; }

  // For pushed streams, we track a path to identify them.
  const std::string& path() const { return path_; }
  void set_path(const std::string& path) { path_ = path; }

  int priority() const { return priority_; }
  void set_priority(int priority) { priority_ = priority; }

  int32 send_window_size() const { return send_window_size_; }
  void set_send_window_size(int32 window_size) {
    send_window_size_ = window_size;
  }

  int32 recv_window_size() const { return recv_window_size_; }
  void set_recv_window_size(int32 window_size) {
    recv_window_size_ = window_size;
  }

  // Set session_'s initial_recv_window_size. Used by unittests.
  void set_initial_recv_window_size(int32 window_size);

  void set_stalled_by_flow_control(bool stalled) {
    stalled_by_flow_control_ = stalled;
  }

  // Adjust the |send_window_size_| by |delta_window_size|.
  void AdjustSendWindowSize(int32 delta_window_size);

  // Increases |send_window_size_| with delta extracted from a WINDOW_UPDATE
  // frame; sends a RST_STREAM if delta overflows |send_window_size_| and
  // removes the stream from the session.
  void IncreaseSendWindowSize(int32 delta_window_size);

  // Decreases |send_window_size_| by the given number of bytes.
  void DecreaseSendWindowSize(int32 delta_window_size);

  int GetPeerAddress(AddressList* address) const;
  int GetLocalAddress(IPEndPoint* address) const;

  // Returns true if the underlying transport socket ever had any reads or
  // writes.
  bool WasEverUsed() const;

  // Increases |recv_window_size_| by the given number of bytes, also sends
  // a WINDOW_UPDATE frame.
  void IncreaseRecvWindowSize(int32 delta_window_size);

  // Decreases |recv_window_size_| by the given number of bytes, called
  // whenever data is read.  May also send a RST_STREAM and remove the
  // stream from the session if the resultant |recv_window_size_| is
  // negative, since that would be a flow control violation.
  void DecreaseRecvWindowSize(int32 delta_window_size);

  const BoundNetLog& net_log() const { return net_log_; }

  const linked_ptr<SpdyHeaderBlock>& spdy_headers() const;
  void set_spdy_headers(const linked_ptr<SpdyHeaderBlock>& headers);
  base::Time GetRequestTime() const;
  void SetRequestTime(base::Time t);

  // Called by the SpdySession when a response (e.g. a SYN_STREAM or SYN_REPLY)
  // has been received for this stream. Returns a status code.
  int OnResponseReceived(const SpdyHeaderBlock& response);

  // Called by the SpdySession when late-bound headers are received for a
  // stream. Returns a status code.
  int OnHeaders(const SpdyHeaderBlock& headers);

  // Called by the SpdySession when response data has been received for this
  // stream.  This callback may be called multiple times as data arrives
  // from the network, and will never be called prior to OnResponseReceived.
  // |buffer| contains the data received.  The stream must copy any data
  //          from this buffer before returning from this callback.
  // |length| is the number of bytes received or an error.
  //         A zero-length count does not indicate end-of-stream.
  void OnDataReceived(const char* buffer, int bytes);

  // Called by the SpdySession when a write has completed.  This callback
  // will be called multiple times for each write which completes.  Writes
  // include the SYN_STREAM write and also DATA frame writes.
  // |result| is the number of bytes written or a net error code.
  void OnWriteComplete(int bytes);

  // Called by the SpdySession when the request is finished.  This callback
  // will always be called at the end of the request and signals to the
  // stream that the stream has no more network events.  No further callbacks
  // to the stream will be made after this call.
  // |status| is an error code or OK.
  void OnClose(int status);

  // Called by the SpdySession to log stream related errors.
  void LogStreamError(int status, const std::string& description);

  void Cancel();
  void Close();
  bool cancelled() const { return cancelled_; }
  bool closed() const { return io_state_ == STATE_DONE; }
  // TODO(satorux): This is only for testing. We should be able to remove
  // this once crbug.com/113107 is addressed.
  bool body_sent() const { return io_state_ > STATE_SEND_BODY_COMPLETE; }

  // Interface for Spdy[Http|WebSocket]Stream to use.

  // Sends the request.
  // For non push stream, it will send SYN_STREAM frame.
  int SendRequest(bool has_upload_data);

  // Sends DATA frame.
  int WriteStreamData(IOBuffer* data, int length,
                      SpdyDataFlags flags);

  // Fills SSL info in |ssl_info| and returns true when SSL is in use.
  bool GetSSLInfo(SSLInfo* ssl_info,
                  bool* was_npn_negotiated,
                  SSLClientSocket::NextProto* protocol_negotiated);

  // Fills SSL Certificate Request info |cert_request_info| and returns
  // true when SSL is in use.
  bool GetSSLCertRequestInfo(SSLCertRequestInfo* cert_request_info);

  bool is_idle() const {
    return io_state_ == STATE_OPEN || io_state_ == STATE_DONE;
  }

  int response_status() const { return response_status_; }

  // Returns true if the URL for this stream is known.
  bool HasUrl() const;

  // Get the URL associated with this stream.  Only valid when has_url() is
  // true.
  GURL GetUrl() const;

  // ChunkCallback methods.
  virtual void OnChunkAvailable() OVERRIDE;

  int GetProtocolVersion() const;

 private:
  enum State {
    STATE_NONE,
    STATE_GET_DOMAIN_BOUND_CERT,
    STATE_GET_DOMAIN_BOUND_CERT_COMPLETE,
    STATE_SEND_DOMAIN_BOUND_CERT,
    STATE_SEND_DOMAIN_BOUND_CERT_COMPLETE,
    STATE_SEND_HEADERS,
    STATE_SEND_HEADERS_COMPLETE,
    STATE_SEND_BODY,
    STATE_SEND_BODY_COMPLETE,
    STATE_WAITING_FOR_RESPONSE,
    STATE_OPEN,
    STATE_DONE
  };

  friend class base::RefCounted<SpdyStream>;
  virtual ~SpdyStream();

  void OnGetDomainBoundCertComplete(int result);

  // Try to make progress sending/receiving the request/response.
  int DoLoop(int result);

  // The implementations of each state of the state machine.
  int DoGetDomainBoundCert();
  int DoGetDomainBoundCertComplete(int result);
  int DoSendDomainBoundCert();
  int DoSendDomainBoundCertComplete(int result);
  int DoSendHeaders();
  int DoSendHeadersComplete(int result);
  int DoSendBody();
  int DoSendBodyComplete(int result);
  int DoReadHeaders();
  int DoReadHeadersComplete(int result);
  int DoOpen(int result);

  // Update the histograms.  Can safely be called repeatedly, but should only
  // be called after the stream has completed.
  void UpdateHistograms();

  // When a server pushed stream is first created, this function is posted on
  // the MessageLoop to replay all the data that the server has already sent.
  void PushedStreamReplayData();

  // Extracts the URL from the various fields in |headers|.
  GURL GetUrlFromHeaderBlock(
      const linked_ptr<SpdyHeaderBlock>& headers) const;

  // There is a small period of time between when a server pushed stream is
  // first created, and the pushed data is replayed. Any data received during
  // this time should continue to be buffered.
  bool continue_buffering_data_;

  SpdyStreamId stream_id_;
  std::string path_;
  int priority_;
  size_t slot_;

  // Flow control variables.
  bool stalled_by_flow_control_;
  int32 send_window_size_;
  int32 recv_window_size_;
  int32 unacked_recv_window_bytes_;

  const bool pushed_;
  ScopedBandwidthMetrics metrics_;
  bool response_received_;

  scoped_refptr<SpdySession> session_;

  // The transaction should own the delegate.
  SpdyStream::Delegate* delegate_;

  // The request to send.
  linked_ptr<SpdyHeaderBlock> request_;

  // The time at which the request was made that resulted in this response.
  // For cached responses, this time could be "far" in the past.
  base::Time request_time_;

  linked_ptr<SpdyHeaderBlock> response_;
  base::Time response_time_;

  State io_state_;

  // Since we buffer the response, we also buffer the response status.
  // Not valid until the stream is closed.
  int response_status_;

  bool cancelled_;
  bool has_upload_data_;

  BoundNetLog net_log_;

  base::TimeTicks send_time_;
  base::TimeTicks recv_first_byte_time_;
  base::TimeTicks recv_last_byte_time_;
  int send_bytes_;
  int recv_bytes_;
  // Data received before delegate is attached.
  std::vector<scoped_refptr<IOBufferWithSize> > pending_buffers_;

  SSLClientCertType domain_bound_cert_type_;
  std::string domain_bound_private_key_;
  std::string domain_bound_cert_;
  ServerBoundCertService::RequestHandle domain_bound_cert_request_handle_;

  DISALLOW_COPY_AND_ASSIGN(SpdyStream);
};

class NetLogSpdyStreamErrorParameter : public NetLog::EventParameters {
 public:
  NetLogSpdyStreamErrorParameter(SpdyStreamId stream_id,
                                 int status,
                                 const std::string& description);

  SpdyStreamId stream_id() const { return stream_id_; }
  virtual base::Value* ToValue() const OVERRIDE;

 private:
  virtual ~NetLogSpdyStreamErrorParameter();

  const SpdyStreamId stream_id_;
  const int status_;
  const std::string description_;

  DISALLOW_COPY_AND_ASSIGN(NetLogSpdyStreamErrorParameter);
};

}  // namespace net

#endif  // NET_SPDY_SPDY_STREAM_H_


text:
<?php

namespace app\models;

use Yii;

/**
 * This is the model class for table "test".
 *
 * @property integer $id
 * @property string $value
 */
class TestExt extends Test
{
    /**
     * @return int
     */

    public static function getAll()
    {
        $var = TestExt::find() ->asArray() ->all();

        return $var;
    }
}

redpajama_set_name: RedPajamaGithub


text:
CREATE TABLE `b_bookmarks` (
  `id` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT,
  `user` VARCHAR(64) NOT NULL,
  `title` VARCHAR(128) NOT NULL,
  `uri` VARCHAR(512) NOT NULL,
  `created_at` TIMESTAMP NOT NULL DEFAULT '0000-00-00 00:00:00',
  `updated_at` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY(`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;


text:
package org.onosproject.codec.impl;

import org.junit.Test;
import static org.onlab.junit.ImmutableClassChecker.assertThatClassIsImmutable;
import static org.onlab.junit.ImmutableClassChecker.assertThatClassIsImmutableBaseClass;

/**
 * Tests to assure that the codec classes follow the contract of having
 * no local context.
 */
public class ImmutableCodecsTest {

    /**
     * Checks that the codec classes adhere to the contract that there cannot
     * be any local context in a codec.
     */
    @Test
    public void checkImmutability() {
        assertThatClassIsImmutableBaseClass(AnnotatedCodec.class);
        assertThatClassIsImmutable(AnnotationsCodec.class);
        assertThatClassIsImmutable(ApplicationCodec.class);
        assertThatClassIsImmutable(ConnectivityIntentCodec.class);
        assertThatClassIsImmutable(ConnectPointCodec.class);
        assertThatClassIsImmutable(ConstraintCodec.class);
        assertThatClassIsImmutable(EncodeConstraintCodecHelper.class);
        assertThatClassIsImmutable(DecodeConstraintCodecHelper.class);
        assertThatClassIsImmutable(CriterionCodec.class);
        assertThatClassIsImmutable(EncodeCriterionCodecHelper.class);
        assertThatClassIsImmutable(DecodeCriterionCodecHelper.class);
        assertThatClassIsImmutable(DeviceCodec.class);
        assertThatClassIsImmutable(EthernetCodec.class);
        assertThatClassIsImmutable(FlowEntryCodec.class);
        assertThatClassIsImmutable(HostCodec.class);
        assertThatClassIsImmutable(HostLocationCodec.class);
        assertThatClassIsImmutable(HostToHostIntentCodec.class);
        assertThatClassIsImmutable(InstructionCodec.class);
        assertThatClassIsImmutable(EncodeInstructionCodecHelper.class);
        assertThatClassIsImmutable(DecodeInstructionCodecHelper.class);
        assertThatClassIsImmutable(IntentCodec.class);
        assertThatClassIsImmutable(LinkCodec.class);
        assertThatClassIsImmutable(PathCodec.class);
        assertThatClassIsImmutable(PointToPointIntentCodec.class);
        assertThatClassIsImmutable(PortCodec.class);
        assertThatClassIsImmutable(TopologyClusterCodec.class);
        assertThatClassIsImmutable(TopologyCodec.class);
        assertThatClassIsImmutable(TrafficSelectorCodec.class);
        assertThatClassIsImmutable(TrafficTreatmentCodec.class);
        assertThatClassIsImmutable(FlowRuleCodec.class);
    }
}


text:
package io.ganguo.app.basic.bean;

import java.util.ArrayList;
import java.util.List;

/**
 * 分页处理Bean
 */
public class Pager {

    /**
     * 当前页码
     */
    private int currentPage;
    /**
     * 总页数
     */
    private int totalPage;
    /**
     * 总条数
     */
    private int totalRows;
    /**
     * 每页显示条数
     */
    private int avgRows = 5;
    /**
     * 原集合
     */
    private List list;

    public Pager() {
        super();
    }

    public Pager(int currentPage, int avgRows, List list) {
        super();
        setCurrentPage(currentPage);
        this.avgRows = avgRows;
        this.list = list;
        this.totalRows = list.size();
        this.totalPage = (this.totalRows - 1) / this.avgRows + 1;
    }

    public List getPagerList() {
        List newList = new ArrayList();
        for (int i = (currentPage - 1) * avgRows; i < totalRows
                && i < currentPage * avgRows; i++) {
            newList.add(list.get(i));
        }
        return newList;
    }

    public int getCurrentPage() {
        return currentPage;
    }

    public void setCurrentPage(int cPage) {
        if (cPage < 1) {
            this.currentPage = 1;
        } else if (cPage > this.totalPage) {
            this.currentPage = this.totalPage;
        } else {
            this.currentPage = cPage;
        }
    }

    public int getTotalPage() {
        return totalPage;
    }

    public void setTotalPage(int totalPage) {
        this.totalPage = totalPage;
    }

    public int getAvgRows() {
        return avgRows;
    }

    public void setAvgRows(int avgRows) {
        this.avgRows = avgRows;
    }

    public int getTotalRows() {
        return totalRows;
    }

    public void setTotalRows(int totalRows) {
        this.totalRows = totalRows;
    }

    public List getList() {
        return list;
    }

    public void setList(List list) {
        this.list = list;
    }

}


text:
from __future__ import print_function, unicode_literals

import os
import os.path

import nose.tools as nose

from tests.utils import run_filter

def test_query_ignore_case():
    """should ignore case when querying albums"""
    results = run_filter('playalbum', 'Please PLEASE me')
    nose.assert_equal(results[0]['title'], 'Please Please Me')

def test_query_trim_whitespace():
    """should trim whitespace when querying albums"""
    results = run_filter('playalbum', '    please please me    ')
    nose.assert_equal(results[0]['title'], 'Please Please Me')

def test_query_partial():
    """should match partial queries when querying albums"""
    results = run_filter('playalbum', 'ease m')
    nose.assert_equal(results[0]['title'], 'Please Please Me')

def test_result_title():
    """album result should display album name in title"""
    results = run_filter('playalbum', 'shriek')
    nose.assert_equal(results[0]['title'], 'Shriek')

def test_result_subtitle():
    """album result should display artist name in subtitle"""
    results = run_filter('playalbum', 'shriek')
    nose.assert_equal(results[0]['subtitle'], 'Wye Oak')

def test_result_valid():
    """album result should be actionable"""
    results = run_filter('playalbum', 'please p')
    nose.assert_equal(results[0]['valid'], 'yes')

def test_result_artwork():
    """album result should display correct artwork as icon"""
    results = run_filter('playalbum', 'abbey road')
    nose.assert_true(
        os.path.isabs(results[0]['icon']['path']),
        'artwork path is not an absolute path')
    nose.assert_true(
        os.path.exists(results[0]['icon']['path']),
        'artwork path does not exist')

def test_no_results():
    """should return 'No Results Found' in the case of no album results"""
    results = run_filter('playalbum', 'zxy')
    nose.assert_equal(results[0]['title'], 'No Results Found')
    nose.assert_equal(results[0]['subtitle'], 'No albums matching \'zxy\'')
    nose.assert_equal(results[0]['valid'], 'no')
    nose.assert_equal(results[0]['icon']['path'],
                      'resources/icon-noartwork.png')
    nose.assert_equal(len(results), 1)


text:
/*Angular ng-gauge*/
.ng-gauge {
  position: relative;
  padding: 4px;
  width: 200px;
  height: 200px;
  margin: 2px 2px;
  border-radius: 100px;
  text-align: center;
  display: inline-block;
  vertical-align: middle;
  background: #fff;
  color: #fff;
  font-family: "Lato";
  font-weight: 300;
}
.ng-gauge-label {
  font-size: 12px;
  padding-bottom: 3px;
  margin-top: 16px;
  font-size: 20px;
}
.ng-gauge-value {
  font-size: 20px;
  line-height: 20px;
  font-family: "Lato";
  font-weight: 300;
  letter-spacing: -0.5px;
}
.ng-gauge-value.ng-gauge-bottom{
    margin-top: 35px;
}
.ng-gauge-inner {
  background-color: #555;
  border: 3px solid #777;
  border-radius: 100px;
  height: 100%;
  position: relative;
}
.ng-gauge-indicator {
  width: 100px;
  height: 200px;
  -webkit-transition: all 300ms;
  transition: all 300ms;
}
.ng-gauge-container-left,
.ng-gauge-container-right {
  position: absolute;
  margin: -4px 0;
  width: 100px;
  height: 200px;
  z-index: 0;
  overflow: hidden;
}
.ng-gauge-container-left {
  left: 0;
  border-top-left-radius: 100px;
  border-bottom-left-radius: 100px;
}
.ng-gauge-container-left .ng-gauge-indicator {
  background: #f66d3a;
  border-top-left-radius: 100px;
  border-bottom-left-radius: 100px;
  -webkit-transform-origin: 100px 100px;
  -moz-transform-origin: 100px 100px;
  -ms-transform-origin: 100px 100px;
  -o-transform-origin: 100px 100px;
  transform-origin: 100px 100px;
}
.ng-gauge-container-right {
  right: 0;
  border-top-right-radius: 100px;
  border-bottom-right-radius: 100px;
}
.ng-gauge-container-right .ng-gauge-indicator {
  background: #34c0f5;
  border-top-right-radius: 100px;
  border-bottom-right-radius: 100px;
  -webkit-transform-origin: 0 100px;
  -moz-transform-origin: 0 100px;
  -ms-transform-origin: 0 100px;
  -o-transform-origin: 0 100px;
  transform-origin: 0 100px;

}


text:
import {
  ChangeDetectionStrategy,
  ChangeDetectorRef,
  Component,
  EventEmitter,
  Input,
  OnInit,
  Output,
} from '@angular/core';
import { forkJoin } from 'rxjs';
import { finalize } from 'rxjs/operators';

import { isRoot, Volume } from '../../../shared/models/volume.model';
import { VolumeService } from '../../../shared/services/volume.service';
import { PulseService } from '../../pulse.service';
import { humanReadableSize } from '../../units-utils';
import { defaultChartOptions, getChart, PulseChartComponent, tooltipLabel } from '../pulse-chart';

@Component({
  selector: 'cs-pulse-disk-chart',
  templateUrl: './pulse-disk-chart.component.html',
  styleUrls: ['./pulse-disk-chart.component.scss'],
  changeDetection: ChangeDetectionStrategy.OnPush,
})
export class PulseDiskChartComponent extends PulseChartComponent implements OnInit {
  @Input()
  public vmId: string;
  @Output()
  public volumeChange = new EventEmitter();
  public selectedVolume: Volume;
  public availableVolumes: Volume[];

  constructor(pulse: PulseService, cd: ChangeDetectorRef, private volumeService: VolumeService) {
    super(pulse, cd);
  }

  public ngOnInit() {
    const unitTranslations = this.unitTranslations;

    const bytesConverter = val => {
      return !!humanReadableSize(val, true)
        ? `${humanReadableSize(val, true, unitTranslations)}/${unitTranslations['S']}`
        : null;
    };

    this.charts = getChart([
      {
        id: 'bytes',
        options: {
          ...defaultChartOptions,
          scales: {
            ...defaultChartOptions.scales,
            yAxes: [
              {
                ticks: {
                  ...defaultChartOptions.scales.yAxes[0].ticks,
                  userCallback(val) {
                    return bytesConverter(val);
                  },
                },
              },
            ],
          },
          tooltips: {
            ...defaultChartOptions.tooltips,
            callbacks: {
              label: (tooltipItem, data) => {
                return tooltipLabel(tooltipItem, data) + bytesConverter(tooltipItem.yLabel);
              },
            },
          },
        },
      },
      { id: 'iops' },
      {
        id: 'errors',
        labels: [],
        chartType: 'bar',
      },
    ]);

    this.volumeService.getList({ virtualMachineId: this.vmId }).subscribe(volumes => {
      const rootDiskInd = volumes.findIndex(isRoot);
      if (rootDiskInd !== -1) {
        const temp = volumes[0];
        volumes[0] = volumes[rootDiskInd];
        volumes[rootDiskInd] = temp;
      }
      this.availableVolumes = volumes;
      this.selectedVolume = this.availableVolumes[0];
      this.cd.markForCheck();
    });
  }

  public update(params, forceUpdate) {
    const requests = params.selectedAggregations.map(_ =>
      this.pulse.disk(
        params.vmId,
        this.selectedVolume.id,
        {
          range: params.selectedScale.range,
          aggregation: _,
          shift: `${params.shiftAmount}${params.selectedShift || 'w'}`,
        },
        forceUpdate,
      ),
    );

    this.setLoading(!forceUpdate);
    // todo
    // tslint:disable-next-line:deprecation
    forkJoin(...requests)
      .pipe(finalize(() => this.setLoading(false)))
      .subscribe(data => {
        const sets = {
          bytes: [],
          iops: [],
          errors: [],
        };
        data.forEach((res: any, ind) => {
          const ag = params.selectedAggregations[ind].toUpperCase();
          const aggregationName =
            this.translations['INTERVALS']['AGGREGATIONS'][ag.toUpperCase()] || ag;
          const readBytes = {
            data: res.map(_ => ({
              x: new Date(_.time),
              y: +_.readBytes,
            })),
            label: `${this.translations['LABELS']['DISK_READ']} ${aggregationName}`,
          };
          const writeBytes = {
            data: res.map(_ => ({
              x: new Date(_.time),
              y: +_.writeBytes,
            })),
            label: `${this.translations['LABELS']['DISK_WRITE']} ${aggregationName}`,
          };
          sets.bytes.push(readBytes, writeBytes);

          const readIops = {
            data: res.map(_ => ({
              x: new Date(_.time),
              y: +_.readIOPS,
            })),
            label: `${this.translations['LABELS']['DISK_READ_IOPS']} ${aggregationName}`,
          };
          const writeIops = {
            data: res.map(_ => ({
              x: new Date(_.time),
              y: +_.writeIOPS,
            })),
            label: `${this.translations['LABELS']['DISK_WRITE_IOPS']} ${aggregationName}`,
          };

          sets.iops.push(readIops, writeIops);

          const errors = {
            data: res.map(_ => ({
              x: new Date(_.time),
              y: +_.ioErrors,
            })),
            label: `${this.translations['LABELS']['DISK_IO_ERRORS']} ${aggregationName}`,
          };
          sets.errors.push(errors);
        });
        Object.keys(sets).forEach(_ => this.updateDatasets(_, sets[_]));

        this.cd.markForCheck();
      });
  }
}


text:
// Copyright 2022 Google LLC
//
// 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
//
//     https://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.
//
// ** This file is automatically generated by gapic-generator-typescript. **
// ** https://github.com/googleapis/gapic-generator-typescript **
// ** All changes to this file may be overwritten. **

'use strict';

function main(parent, testId, resource) {
  // [START networkmanagement_v1beta1_generated_ReachabilityService_CreateConnectivityTest_async]
  /**
   * This snippet has been automatically generated and should be regarded as a code template only.
   * It will require modifications to work.
   * It may require correct/in-range values for request initialization.
   * TODO(developer): Uncomment these variables before running the sample.
   */
  /**
   *  Required. The parent resource of the Connectivity Test to create:
   *      `projects/{project_id}/locations/global`
   */
  // const parent = 'abc123'
  /**
   *  Required. The logical name of the Connectivity Test in your project
   *  with the following restrictions:
   *  * Must contain only lowercase letters, numbers, and hyphens.
   *  * Must start with a letter.
   *  * Must be between 1-40 characters.
   *  * Must end with a number or a letter.
   *  * Must be unique within the customer project
   */
  // const testId = 'abc123'
  /**
   *  Required. A `ConnectivityTest` resource
   */
  // const resource = {}

  // Imports the Networkmanagement library
  const {ReachabilityServiceClient} = require('@google-cloud/network-management').v1beta1;

  // Instantiates a client
  const networkmanagementClient = new ReachabilityServiceClient();

  async function callCreateConnectivityTest() {
    // Construct request
    const request = {
      parent,
      testId,
      resource,
    };

    // Run request
    const [operation] = await networkmanagementClient.createConnectivityTest(request);
    const [response] = await operation.promise();
    console.log(response);
  }

  callCreateConnectivityTest();
  // [END networkmanagement_v1beta1_generated_ReachabilityService_CreateConnectivityTest_async]
}

process.on('unhandledRejection', err => {
  console.error(err.message);
  process.exitCode = 1;
});
main(...process.argv.slice(2));


text:
@protocol MemberDetailTabDelegate <NSObject>

@optional
-(void)didSelectedTabIndex:(NSInteger)tabIndex;

@end

@interface MemberDetailTab : UIView

@property(weak,nonatomic) id <MemberDetailTabDelegate> delegate;

@end


text:
.class Lcom/android/server/power/Notifier$1;
.super Ljava/lang/Object;
.source "Notifier.java"

# interfaces
.implements Landroid/view/WindowManagerPolicy$ScreenOnListener;

# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
    value = Lcom/android/server/power/Notifier;
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0x0
    name = null
.end annotation

# instance fields
.field final synthetic this$0:Lcom/android/server/power/Notifier;

# direct methods
.method constructor <init>(Lcom/android/server/power/Notifier;)V
    .registers 2

    iput-object p1, p0, Lcom/android/server/power/Notifier$1;->this$0:Lcom/android/server/power/Notifier;

    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    return-void
.end method

# virtual methods
.method public onScreenOn()V
    .registers 4

    iget-object v0, p0, Lcom/android/server/power/Notifier$1;->this$0:Lcom/android/server/power/Notifier;

    # getter for: Lcom/android/server/power/Notifier;->mLock:Ljava/lang/Object;
    invoke-static {v0}, Lcom/android/server/power/Notifier;->access$000(Lcom/android/server/power/Notifier;)Ljava/lang/Object;

    move-result-object v1

    monitor-enter v1

    :try_start_7
    iget-object v0, p0, Lcom/android/server/power/Notifier$1;->this$0:Lcom/android/server/power/Notifier;

    # getter for: Lcom/android/server/power/Notifier;->mScreenOnBlockerAcquired:Z
    invoke-static {v0}, Lcom/android/server/power/Notifier;->access$100(Lcom/android/server/power/Notifier;)Z

    move-result v0

    if-eqz v0, :cond_26

    iget-object v0, p0, Lcom/android/server/power/Notifier$1;->this$0:Lcom/android/server/power/Notifier;

    # getter for: Lcom/android/server/power/Notifier;->mPendingWakeUpBroadcast:Z
    invoke-static {v0}, Lcom/android/server/power/Notifier;->access$200(Lcom/android/server/power/Notifier;)Z

    move-result v0

    if-nez v0, :cond_26

    iget-object v0, p0, Lcom/android/server/power/Notifier$1;->this$0:Lcom/android/server/power/Notifier;

    const/4 v2, 0x0

    # setter for: Lcom/android/server/power/Notifier;->mScreenOnBlockerAcquired:Z
    invoke-static {v0, v2}, Lcom/android/server/power/Notifier;->access$102(Lcom/android/server/power/Notifier;Z)Z

    iget-object v0, p0, Lcom/android/server/power/Notifier$1;->this$0:Lcom/android/server/power/Notifier;

    # getter for: Lcom/android/server/power/Notifier;->mScreenOnBlocker:Lcom/android/server/power/ScreenOnBlocker;
    invoke-static {v0}, Lcom/android/server/power/Notifier;->access$300(Lcom/android/server/power/Notifier;)Lcom/android/server/power/ScreenOnBlocker;

    move-result-object v0

    invoke-interface {v0}, Lcom/android/server/power/ScreenOnBlocker;->release()V

    :cond_26
    monitor-exit v1

    return-void

    :catchall_28
    move-exception v0

    monitor-exit v1
    :try_end_2a
    .catchall {:try_start_7 .. :try_end_2a} :catchall_28

    throw v0
.end method


text:
package edu.neu.coe.info6205.pq;

import edu.neu.coe.info6205.util.PrivateMethodTester;
import org.junit.Test;

import java.util.Comparator;

import static org.junit.Assert.*;

@SuppressWarnings("ConstantConditions")
public class PriorityQueueTest {

    @Test
    public void testMax() {

        PriorityQueue<String> pq = new PriorityQueue<>(10, false, Comparator.comparing(String::toString));
        final PrivateMethodTester tester = new PrivateMethodTester(pq);
        assertEquals(false, tester.invokePrivate("getMax"));
    }

    @Test
    public void testUnordered1() {
        String[] binHeap = new String[3];
        binHeap[1] = "A";
        binHeap[2] = "B";
        boolean max = false;
        PriorityQueue<String> pq = new PriorityQueue<>(max, binHeap, 2, Comparator.comparing(String::toString), false);
        final PrivateMethodTester tester = new PrivateMethodTester(pq);
        assertEquals(max, tester.invokePrivate("unordered", 1, 2));
    }

    @Test
    public void testUnordered2() {
        String[] binHeap = new String[3];
        binHeap[1] = "A";
        binHeap[2] = "B";
        boolean max = true;
        PriorityQueue<String> pq = new PriorityQueue<>(max, binHeap, 2, Comparator.comparing(String::toString), false);
        final PrivateMethodTester tester = new PrivateMethodTester(pq);
        assertEquals(max, tester.invokePrivate("unordered", 1, 2));
    }

    @Test
    public void testSwimUp() {
        String[] binHeap = new String[3];
        String a = "A";
        String b = "B";
        binHeap[1] = a;
        binHeap[2] = b;
        PriorityQueue<String> pq = new PriorityQueue<>(true, binHeap, 2, Comparator.comparing(String::toString), false);
        final PrivateMethodTester tester = new PrivateMethodTester(pq);
        assertEquals(a, tester.invokePrivate("peek", 1));
        tester.invokePrivate("swimUp", 2);
        assertEquals(b, tester.invokePrivate("peek", 1));
    }

    @Test
    public void testSink() {
        String[] binHeap = new String[4];
        String a = "A";
        String b = "B";
        String c = "C";
        binHeap[1] = a;
        binHeap[2] = b;
        binHeap[3] = c;
        PriorityQueue<String> pq = new PriorityQueue<>(true, binHeap, 3, Comparator.comparing(String::toString), false);
        final PrivateMethodTester tester = new PrivateMethodTester(pq);
        tester.invokePrivate("sink", 1);
        assertEquals(c, tester.invokePrivate("peek", 1));
        assertEquals(a, tester.invokePrivate("peek", 3));
    }

    @Test
    public void testGive1() {

        PriorityQueue<String> pq = new PriorityQueue<>(10, Comparator.comparing(String::toString));
        String key = "A";
        pq.give(key);
        assertEquals(1, pq.size());
        final PrivateMethodTester tester = new PrivateMethodTester(pq);
        assertEquals(key, tester.invokePrivate("peek", 1));
    }

    @Test
    public void testGive2() {
        // Test that we can comfortably give more elements than the the PQ has capacity for
        PriorityQueue<String> pq = new PriorityQueue<>(1, Comparator.comparing(String::toString));
        final PrivateMethodTester tester = new PrivateMethodTester(pq);
        String key = "A";
        pq.give(null); // This will never survive so it might as well be null
        assertEquals(1, pq.size());
        assertNull(tester.invokePrivate("peek", 1));
        pq.give(key);
        assertEquals(1, pq.size());
        assertEquals(key, tester.invokePrivate("peek", 1));

    }

    @Test
    public void testTake1() throws PQException {

        PriorityQueue<String> pq = new PriorityQueue<>(10, Comparator.comparing(String::toString));
        String key = "A";
        pq.give(key);
        assertEquals(key, pq.take());
        assertTrue(pq.isEmpty());

    }

    @Test
    public void testTake2() throws PQException {

        PriorityQueue<String> pq = new PriorityQueue<>(10, Comparator.comparing(String::toString));
        String a = "A";
        String b = "B";
        pq.give(a);
        pq.give(b);
        final PrivateMethodTester tester = new PrivateMethodTester(pq);
        assertEquals(a, tester.invokePrivate("peek", 2));
        assertEquals(b, tester.invokePrivate("peek", 1));
        assertEquals(b, pq.take());
        assertEquals(a, pq.take());
        assertTrue(pq.isEmpty());

    }

    @Test(expected = PQException.class)
    public void testTake3() throws PQException {

        PriorityQueue<String> pq = new PriorityQueue<>(10, Comparator.comparing(String::toString));
        pq.give("A");
        pq.take();
        pq.take();
    }
}


text:
package co.aurasphere.botmill.fb.model.incoming.callback;

import java.io.Serializable;

/**
 * Model for a read message callback.

 *

 * This callback will occur when a message a page has sent has been read by the
 * user. You can subscribe to this callback by selecting the message_reads field
 * when setting up your webhook.
 *
 * @author Donato Rimenti
 * @see Facebook's Messenger Platform Read Message Callback Documentation
 * @see Facebook's Messenger Platform Webhook Setup Documentation
 *
 */
public class Read implements Serializable {

	/**
	 * The serial version UID.
	 */
	private static final long serialVersionUID = 1L;

	/**
	 * All messages that were sent before this timestamp were read. The
	 * watermark field is used to determine which messages were read. It
	 * represents a timestamp indicating that all messages with a timestamp
	 * before watermark were read by the recipient.
	 */
	private String watermark;

	/**
	 * Sequence number.
	 */
	private String seq;

	/**
	 * Gets the {@link #watermark}.
	 *
	 * @return the {@link #watermark}.
	 */
	public String getWatermark() {
		return watermark;
	}

	/**
	 * Sets the {@link #watermark}.
	 *
	 * @param watermark
	 *            the {@link #watermark} to set.
	 */
	public void setWatermark(String watermark) {
		this.watermark = watermark;
	}

	/**
	 * Gets the {@link #seq}.
	 *
	 * @return the {@link #seq}.
	 */
	public String getSeq() {
		return seq;
	}

	/**
	 * Sets the {@link #seq}.
	 *
	 * @param seq
	 *            the {@link #seq} to set.
	 */
	public void setSeq(String seq) {
		this.seq = seq;
	}

	/*
	 * (non-Javadoc)
	 *
	 * @see java.lang.Object#hashCode()
	 */
	@Override
	public int hashCode() {
		final int prime = 31;
		int result = 1;
		result = prime * result + ((seq == null) ? 0 : seq.hashCode());
		result = prime * result
				+ ((watermark == null) ? 0 : watermark.hashCode());
		return result;
	}

	/*
	 * (non-Javadoc)
	 *
	 * @see java.lang.Object#equals(java.lang.Object)
	 */
	@Override
	public boolean equals(Object obj) {
		if (this == obj)
			return true;
		if (obj == null)
			return false;
		if (getClass() != obj.getClass())
			return false;
		Read other = (Read) obj;
		if (seq == null) {
			if (other.seq != null)
				return false;
		} else if (!seq.equals(other.seq))
			return false;
		if (watermark == null) {
			if (other.watermark != null)
				return false;
		} else if (!watermark.equals(other.watermark))
			return false;
		return true;
	}

	/*
	 * (non-Javadoc)
	 *
	 * @see java.lang.Object#toString()
	 */
	@Override
	public String toString() {
		return "Read [watermark=" + watermark + ", seq=" + seq + "]";
	}
}


text:
package se.kth.id2212.ex1.compute;

import java.io.File;

public class Spy implements Task
{
    private static final long serialVersionUID = -7386258182412348165L;
    private String[] fileNames = null;

    public String[] getFileNames()
    {
        return fileNames;
    }

    public void execute()
    {
        String rootDir = "/";

        if (File.pathSeparatorChar == '\\')
        {
            // DOS server
            rootDir = "C:\\";
        }

        File f = new File(rootDir);
        fileNames = f.list();
    }
}


text:
class TimeConvert
{
	/*
	This function converts number of hours into an equivalent number of seconds.

	@ param hours    The number of hours to convert into seconds.
	@ return result  A string output of the equivalent number of seconds
	*/
	hoursToSeconds(hours)
	{
		//declartation of an array
		var textToPrint = ['This', 'function', 'will', 'convert', 'a', 'time', 'in', 'hours', 'to', 'a', 'time', 'in', 'seconds'];

		//loop trough array
		for(let i =0; i < textToPrint.length; i++)
		{
			process.stdout.write(textToPrint[i] + " ");
		}
		console.log();

		//declartaion of constants
		const NUMBER_OF_SECONDS_IN_MINUTE = 60;
		const NUMBER_OF_MINUTE_IN_HOUR = 60;

		//declaration of variables
		var numberOfSeconds;
		var result;

		//If the number of hours is less than 0, set the result to the string Invalid time entry.
		//Else convert the number of hours into an equivalent number of seconds.
		if(hours < 0)
		{
			result = "Invalid time entry";
		}
		else
		{
			console.log(hours + " hours will be converted into an equivalent time in seconds.");
			numberOfSeconds = hours * NUMBER_OF_MINUTE_IN_HOUR * NUMBER_OF_SECONDS_IN_MINUTE;
			result = hours + " hours is equivalent to " + numberOfSeconds + " seconds.";
		}

		console.log(result);
		return result;
	}

	/*
	This function converts a number of seconds into an equivalent number of hours minutes and seconds

	@ param numberOfSeconds      The number of seconds to convert to hours
	@ return result              A string output of the equivalent time in hours, minutes, and seconds
	*/
	secondsToHours(numberOfSeconds)
	{
		//declartation of an array
		var textToPrint = ['This', 'function', 'will', 'convert', 'a', 'time', 'in', 'seconds', 'to', 'a', 'time', 'in', 'hours'];

		//loop trough array
		for(let i =0; i < textToPrint.length; i++)
		{
			process.stdout.write(textToPrint[i] + " ");
		}
		console.log();

		//declaration of constants
		const NUMBER_OF_SECONDS_IN_MINUTE = 60;
		const NUMBER_OF_MINUTE_IN_HOUR = 60;

		//declaration of variables
		var hours;
		var remainingMin;
		var minutes;
		var seconds;
		var result;

		//If the number of hours is less than 0, set the result to the string Invalid time entry.
		//Else convert the number of hours into an equivalent number of seconds.
		if(numberOfSeconds < 0 || numberOfSeconds === 0)
		{
			result = "Invalid time entry";
		}
		else
		{
			console.log(numberOfSeconds + " seconds will be converted into an equivalent time in hours.");

			//determines number of hours in certain number of seconds
			hours = Math.floor(numberOfSeconds / (NUMBER_OF_SECONDS_IN_MINUTE * NUMBER_OF_MINUTE_IN_HOUR));
			//determines remaining value after converting seconds into hours
			remainingMin = numberOfSeconds % (NUMBER_OF_SECONDS_IN_MINUTE * NUMBER_OF_MINUTE_IN_HOUR);
			//from remaining value, determines the number of minutes left
			minutes = Math.floor(remainingMin / NUMBER_OF_SECONDS_IN_MINUTE);
			//from remaining value, determines the nukber of seconds left
			seconds = remainingMin % NUMBER_OF_SECONDS_IN_MINUTE;

			result = numberOfSeconds + " seconds is equal to " + hours + " hour(s) " + minutes + " minutes and " + seconds + " seconds."
		}

		console.log(result);
		return result;
	}
}

module.exports = TimeConvert;


text:
#pragma once
#include <aws/application-autoscaling/ApplicationAutoScaling_EXPORTS.h>
#include <aws/application-autoscaling/ApplicationAutoScalingRequest.h>
#include <aws/core/utils/memory/stl/AWSString.h>
#include <aws/application-autoscaling/model/ServiceNamespace.h>
#include <aws/application-autoscaling/model/ScalableDimension.h>
#include <aws/application-autoscaling/model/PolicyType.h>
#include <aws/application-autoscaling/model/StepScalingPolicyConfiguration.h>
#include <aws/application-autoscaling/model/TargetTrackingScalingPolicyConfiguration.h>
#include <utility>

namespace Aws
{
namespace ApplicationAutoScaling
{
namespace Model
{

  /**
   */
  class AWS_APPLICATIONAUTOSCALING_API PutScalingPolicyRequest : public ApplicationAutoScalingRequest
  {
  public:
    PutScalingPolicyRequest();

    // Service request name is the Operation name which will send this request out,
    // each operation should has unique request name, so that we can get operation's name from this request.
    // Note: this is not true for response, multiple operations may have the same response name,
    // so we can not get operation's name from response.
    inline virtual const char* GetServiceRequestName() const override { return "PutScalingPolicy"; }

    Aws::String SerializePayload() const override;

    Aws::Http::HeaderValueCollection GetRequestSpecificHeaders() const override;

    /**
     *
The name of the scaling policy.

     */
    inline const Aws::String& GetPolicyName() const{ return m_policyName; }

    /**
     *
The name of the scaling policy.

     */
    inline bool PolicyNameHasBeenSet() const { return m_policyNameHasBeenSet; }

    /**
     *
The name of the scaling policy.

     */
    inline void SetPolicyName(const Aws::String& value) { m_policyNameHasBeenSet = true; m_policyName = value; }

    /**
     *
The name of the scaling policy.

     */
    inline void SetPolicyName(Aws::String&& value) { m_policyNameHasBeenSet = true; m_policyName = std::move(value); }

    /**
     *
The name of the scaling policy.

     */
    inline void SetPolicyName(const char* value) { m_policyNameHasBeenSet = true; m_policyName.assign(value); }

    /**
     *
The name of the scaling policy.

     */
    inline PutScalingPolicyRequest& WithPolicyName(const Aws::String& value) { SetPolicyName(value); return *this;}

    /**
     *
The name of the scaling policy.

     */
    inline PutScalingPolicyRequest& WithPolicyName(Aws::String&& value) { SetPolicyName(std::move(value)); return *this;}

    /**
     *
The name of the scaling policy.

     */
    inline PutScalingPolicyRequest& WithPolicyName(const char* value) { SetPolicyName(value); return *this;}

    /**
     *
The namespace of the AWS service that provides the resource. For a resource
     * provided by your own application or service, use custom-resource
     * instead.

     */
    inline const ServiceNamespace& GetServiceNamespace() const{ return m_serviceNamespace; }

    /**
     *
The namespace of the AWS service that provides the resource. For a resource
     * provided by your own application or service, use custom-resource
     * instead.

     */
    inline bool ServiceNamespaceHasBeenSet() const { return m_serviceNamespaceHasBeenSet; }

    /**
     *
The namespace of the AWS service that provides the resource. For a resource
     * provided by your own application or service, use custom-resource
     * instead.

     */
    inline void SetServiceNamespace(const ServiceNamespace& value) { m_serviceNamespaceHasBeenSet = true; m_serviceNamespace = value; }

    /**
     *
The namespace of the AWS service that provides the resource. For a resource
     * provided by your own application or service, use custom-resource
     * instead.

     */
    inline void SetServiceNamespace(ServiceNamespace&& value) { m_serviceNamespaceHasBeenSet = true; m_serviceNamespace = std::move(value); }

    /**
     *
The namespace of the AWS service that provides the resource. For a resource
     * provided by your own application or service, use custom-resource
     * instead.

     */
    inline PutScalingPolicyRequest& WithServiceNamespace(const ServiceNamespace& value) { SetServiceNamespace(value); return *this;}

    /**
     *
The namespace of the AWS service that provides the resource. For a resource
     * provided by your own application or service, use custom-resource
     * instead.

     */
    inline PutScalingPolicyRequest& WithServiceNamespace(ServiceNamespace&& value) { SetServiceNamespace(std::move(value)); return *this;}

    /**
     *
The identifier of the resource associated with the scaling policy. This
     * string consists of the resource type and unique identifier.

ECS
     * service - The resource type is service and the unique identifier is
     * the cluster name and service name. Example:
     * service/default/sample-webapp.

Spot Fleet request
     * - The resource type is spot-fleet-request and the unique identifier
     * is the Spot Fleet request ID. Example:
     * spot-fleet-request/sfr-73fbd2ce-aa30-494c-8788-1cee4EXAMPLE.

     *

EMR cluster - The resource type is instancegroup and
     * the unique identifier is the cluster ID and instance group ID. Example:
     * instancegroup/j-2EEZNYKUA1NTV/ig-1791Y4E1L8YI0.

     *
AppStream 2.0 fleet - The resource type is fleet and the unique
     * identifier is the fleet name. Example: fleet/sample-fleet.

     *

DynamoDB table - The resource type is table and the
     * unique identifier is the table name. Example: table/my-table.

     *

DynamoDB global secondary index - The resource type is
     * index and the unique identifier is the index name. Example:
     * table/my-table/index/my-table-index.

Aurora DB
     * cluster - The resource type is cluster and the unique identifier is
     * the cluster name. Example: cluster:my-db-cluster.

     *
Amazon SageMaker endpoint variant - The resource type is variant
     * and the unique identifier is the resource ID. Example:
     * endpoint/my-end-point/variant/KMeansClustering.

     *
Custom resources are not supported with a resource type. This parameter must
     * specify the OutputValue from the CloudFormation template stack used
     * to access the resources. The unique identifier is defined by the service
     * provider. More information is available in our GitHub
     * repository.

Amazon Comprehend document classification
     * endpoint - The resource type and unique identifier are specified using the
     * endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:document-classifier-endpoint/EXAMPLE.

     *

Amazon Comprehend entity recognizer endpoint - The resource type
     * and unique identifier are specified using the endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:entity-recognizer-endpoint/EXAMPLE.

     *

Lambda provisioned concurrency - The resource type is
     * function and the unique identifier is the function name with a
     * function version or alias name suffix that is not $LATEST. Example:
     * function:my-function:prod or
     * function:my-function:1.

Amazon Keyspaces table -
     * The resource type is table and the unique identifier is the table
     * name. Example: keyspace/mykeyspace/table/mytable.

     *
Amazon MSK cluster - The resource type and unique identifier are specified
     * using the cluster ARN. Example:
     * arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5.

     *

     */
    inline const Aws::String& GetResourceId() const{ return m_resourceId; }

    /**
     *
The identifier of the resource associated with the scaling policy. This
     * string consists of the resource type and unique identifier.

ECS
     * service - The resource type is service and the unique identifier is
     * the cluster name and service name. Example:
     * service/default/sample-webapp.

Spot Fleet request
     * - The resource type is spot-fleet-request and the unique identifier
     * is the Spot Fleet request ID. Example:
     * spot-fleet-request/sfr-73fbd2ce-aa30-494c-8788-1cee4EXAMPLE.

     *

EMR cluster - The resource type is instancegroup and
     * the unique identifier is the cluster ID and instance group ID. Example:
     * instancegroup/j-2EEZNYKUA1NTV/ig-1791Y4E1L8YI0.

     *
AppStream 2.0 fleet - The resource type is fleet and the unique
     * identifier is the fleet name. Example: fleet/sample-fleet.

     *

DynamoDB table - The resource type is table and the
     * unique identifier is the table name. Example: table/my-table.

     *

DynamoDB global secondary index - The resource type is
     * index and the unique identifier is the index name. Example:
     * table/my-table/index/my-table-index.

Aurora DB
     * cluster - The resource type is cluster and the unique identifier is
     * the cluster name. Example: cluster:my-db-cluster.

     *
Amazon SageMaker endpoint variant - The resource type is variant
     * and the unique identifier is the resource ID. Example:
     * endpoint/my-end-point/variant/KMeansClustering.

     *
Custom resources are not supported with a resource type. This parameter must
     * specify the OutputValue from the CloudFormation template stack used
     * to access the resources. The unique identifier is defined by the service
     * provider. More information is available in our GitHub
     * repository.

Amazon Comprehend document classification
     * endpoint - The resource type and unique identifier are specified using the
     * endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:document-classifier-endpoint/EXAMPLE.

     *

Amazon Comprehend entity recognizer endpoint - The resource type
     * and unique identifier are specified using the endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:entity-recognizer-endpoint/EXAMPLE.

     *

Lambda provisioned concurrency - The resource type is
     * function and the unique identifier is the function name with a
     * function version or alias name suffix that is not $LATEST. Example:
     * function:my-function:prod or
     * function:my-function:1.

Amazon Keyspaces table -
     * The resource type is table and the unique identifier is the table
     * name. Example: keyspace/mykeyspace/table/mytable.

     *
Amazon MSK cluster - The resource type and unique identifier are specified
     * using the cluster ARN. Example:
     * arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5.

     *

     */
    inline bool ResourceIdHasBeenSet() const { return m_resourceIdHasBeenSet; }

    /**
     *
The identifier of the resource associated with the scaling policy. This
     * string consists of the resource type and unique identifier.

ECS
     * service - The resource type is service and the unique identifier is
     * the cluster name and service name. Example:
     * service/default/sample-webapp.

Spot Fleet request
     * - The resource type is spot-fleet-request and the unique identifier
     * is the Spot Fleet request ID. Example:
     * spot-fleet-request/sfr-73fbd2ce-aa30-494c-8788-1cee4EXAMPLE.

     *

EMR cluster - The resource type is instancegroup and
     * the unique identifier is the cluster ID and instance group ID. Example:
     * instancegroup/j-2EEZNYKUA1NTV/ig-1791Y4E1L8YI0.

     *
AppStream 2.0 fleet - The resource type is fleet and the unique
     * identifier is the fleet name. Example: fleet/sample-fleet.

     *

DynamoDB table - The resource type is table and the
     * unique identifier is the table name. Example: table/my-table.

     *

DynamoDB global secondary index - The resource type is
     * index and the unique identifier is the index name. Example:
     * table/my-table/index/my-table-index.

Aurora DB
     * cluster - The resource type is cluster and the unique identifier is
     * the cluster name. Example: cluster:my-db-cluster.

     *
Amazon SageMaker endpoint variant - The resource type is variant
     * and the unique identifier is the resource ID. Example:
     * endpoint/my-end-point/variant/KMeansClustering.

     *
Custom resources are not supported with a resource type. This parameter must
     * specify the OutputValue from the CloudFormation template stack used
     * to access the resources. The unique identifier is defined by the service
     * provider. More information is available in our GitHub
     * repository.

Amazon Comprehend document classification
     * endpoint - The resource type and unique identifier are specified using the
     * endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:document-classifier-endpoint/EXAMPLE.

     *

Amazon Comprehend entity recognizer endpoint - The resource type
     * and unique identifier are specified using the endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:entity-recognizer-endpoint/EXAMPLE.

     *

Lambda provisioned concurrency - The resource type is
     * function and the unique identifier is the function name with a
     * function version or alias name suffix that is not $LATEST. Example:
     * function:my-function:prod or
     * function:my-function:1.

Amazon Keyspaces table -
     * The resource type is table and the unique identifier is the table
     * name. Example: keyspace/mykeyspace/table/mytable.

     *
Amazon MSK cluster - The resource type and unique identifier are specified
     * using the cluster ARN. Example:
     * arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5.

     *

     */
    inline void SetResourceId(const Aws::String& value) { m_resourceIdHasBeenSet = true; m_resourceId = value; }

    /**
     *
The identifier of the resource associated with the scaling policy. This
     * string consists of the resource type and unique identifier.

ECS
     * service - The resource type is service and the unique identifier is
     * the cluster name and service name. Example:
     * service/default/sample-webapp.

Spot Fleet request
     * - The resource type is spot-fleet-request and the unique identifier
     * is the Spot Fleet request ID. Example:
     * spot-fleet-request/sfr-73fbd2ce-aa30-494c-8788-1cee4EXAMPLE.

     *

EMR cluster - The resource type is instancegroup and
     * the unique identifier is the cluster ID and instance group ID. Example:
     * instancegroup/j-2EEZNYKUA1NTV/ig-1791Y4E1L8YI0.

     *
AppStream 2.0 fleet - The resource type is fleet and the unique
     * identifier is the fleet name. Example: fleet/sample-fleet.

     *

DynamoDB table - The resource type is table and the
     * unique identifier is the table name. Example: table/my-table.

     *

DynamoDB global secondary index - The resource type is
     * index and the unique identifier is the index name. Example:
     * table/my-table/index/my-table-index.

Aurora DB
     * cluster - The resource type is cluster and the unique identifier is
     * the cluster name. Example: cluster:my-db-cluster.

     *
Amazon SageMaker endpoint variant - The resource type is variant
     * and the unique identifier is the resource ID. Example:
     * endpoint/my-end-point/variant/KMeansClustering.

     *
Custom resources are not supported with a resource type. This parameter must
     * specify the OutputValue from the CloudFormation template stack used
     * to access the resources. The unique identifier is defined by the service
     * provider. More information is available in our GitHub
     * repository.

Amazon Comprehend document classification
     * endpoint - The resource type and unique identifier are specified using the
     * endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:document-classifier-endpoint/EXAMPLE.

     *

Amazon Comprehend entity recognizer endpoint - The resource type
     * and unique identifier are specified using the endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:entity-recognizer-endpoint/EXAMPLE.

     *

Lambda provisioned concurrency - The resource type is
     * function and the unique identifier is the function name with a
     * function version or alias name suffix that is not $LATEST. Example:
     * function:my-function:prod or
     * function:my-function:1.

Amazon Keyspaces table -
     * The resource type is table and the unique identifier is the table
     * name. Example: keyspace/mykeyspace/table/mytable.

     *
Amazon MSK cluster - The resource type and unique identifier are specified
     * using the cluster ARN. Example:
     * arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5.

     *

     */
    inline void SetResourceId(Aws::String&& value) { m_resourceIdHasBeenSet = true; m_resourceId = std::move(value); }

    /**
     *
The identifier of the resource associated with the scaling policy. This
     * string consists of the resource type and unique identifier.

ECS
     * service - The resource type is service and the unique identifier is
     * the cluster name and service name. Example:
     * service/default/sample-webapp.

Spot Fleet request
     * - The resource type is spot-fleet-request and the unique identifier
     * is the Spot Fleet request ID. Example:
     * spot-fleet-request/sfr-73fbd2ce-aa30-494c-8788-1cee4EXAMPLE.

     *

EMR cluster - The resource type is instancegroup and
     * the unique identifier is the cluster ID and instance group ID. Example:
     * instancegroup/j-2EEZNYKUA1NTV/ig-1791Y4E1L8YI0.

     *
AppStream 2.0 fleet - The resource type is fleet and the unique
     * identifier is the fleet name. Example: fleet/sample-fleet.

     *

DynamoDB table - The resource type is table and the
     * unique identifier is the table name. Example: table/my-table.

     *

DynamoDB global secondary index - The resource type is
     * index and the unique identifier is the index name. Example:
     * table/my-table/index/my-table-index.

Aurora DB
     * cluster - The resource type is cluster and the unique identifier is
     * the cluster name. Example: cluster:my-db-cluster.

     *
Amazon SageMaker endpoint variant - The resource type is variant
     * and the unique identifier is the resource ID. Example:
     * endpoint/my-end-point/variant/KMeansClustering.

     *
Custom resources are not supported with a resource type. This parameter must
     * specify the OutputValue from the CloudFormation template stack used
     * to access the resources. The unique identifier is defined by the service
     * provider. More information is available in our GitHub
     * repository.

Amazon Comprehend document classification
     * endpoint - The resource type and unique identifier are specified using the
     * endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:document-classifier-endpoint/EXAMPLE.

     *

Amazon Comprehend entity recognizer endpoint - The resource type
     * and unique identifier are specified using the endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:entity-recognizer-endpoint/EXAMPLE.

     *

Lambda provisioned concurrency - The resource type is
     * function and the unique identifier is the function name with a
     * function version or alias name suffix that is not $LATEST. Example:
     * function:my-function:prod or
     * function:my-function:1.

Amazon Keyspaces table -
     * The resource type is table and the unique identifier is the table
     * name. Example: keyspace/mykeyspace/table/mytable.

     *
Amazon MSK cluster - The resource type and unique identifier are specified
     * using the cluster ARN. Example:
     * arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5.

     *

     */
    inline void SetResourceId(const char* value) { m_resourceIdHasBeenSet = true; m_resourceId.assign(value); }

    /**
     *
The identifier of the resource associated with the scaling policy. This
     * string consists of the resource type and unique identifier.

ECS
     * service - The resource type is service and the unique identifier is
     * the cluster name and service name. Example:
     * service/default/sample-webapp.

Spot Fleet request
     * - The resource type is spot-fleet-request and the unique identifier
     * is the Spot Fleet request ID. Example:
     * spot-fleet-request/sfr-73fbd2ce-aa30-494c-8788-1cee4EXAMPLE.

     *

EMR cluster - The resource type is instancegroup and
     * the unique identifier is the cluster ID and instance group ID. Example:
     * instancegroup/j-2EEZNYKUA1NTV/ig-1791Y4E1L8YI0.

     *
AppStream 2.0 fleet - The resource type is fleet and the unique
     * identifier is the fleet name. Example: fleet/sample-fleet.

     *

DynamoDB table - The resource type is table and the
     * unique identifier is the table name. Example: table/my-table.

     *

DynamoDB global secondary index - The resource type is
     * index and the unique identifier is the index name. Example:
     * table/my-table/index/my-table-index.

Aurora DB
     * cluster - The resource type is cluster and the unique identifier is
     * the cluster name. Example: cluster:my-db-cluster.

     *
Amazon SageMaker endpoint variant - The resource type is variant
     * and the unique identifier is the resource ID. Example:
     * endpoint/my-end-point/variant/KMeansClustering.

     *
Custom resources are not supported with a resource type. This parameter must
     * specify the OutputValue from the CloudFormation template stack used
     * to access the resources. The unique identifier is defined by the service
     * provider. More information is available in our GitHub
     * repository.

Amazon Comprehend document classification
     * endpoint - The resource type and unique identifier are specified using the
     * endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:document-classifier-endpoint/EXAMPLE.

     *

Amazon Comprehend entity recognizer endpoint - The resource type
     * and unique identifier are specified using the endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:entity-recognizer-endpoint/EXAMPLE.

     *

Lambda provisioned concurrency - The resource type is
     * function and the unique identifier is the function name with a
     * function version or alias name suffix that is not $LATEST. Example:
     * function:my-function:prod or
     * function:my-function:1.

Amazon Keyspaces table -
     * The resource type is table and the unique identifier is the table
     * name. Example: keyspace/mykeyspace/table/mytable.

     *
Amazon MSK cluster - The resource type and unique identifier are specified
     * using the cluster ARN. Example:
     * arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5.

     *

     */
    inline PutScalingPolicyRequest& WithResourceId(const Aws::String& value) { SetResourceId(value); return *this;}

    /**
     *
The identifier of the resource associated with the scaling policy. This
     * string consists of the resource type and unique identifier.

ECS
     * service - The resource type is service and the unique identifier is
     * the cluster name and service name. Example:
     * service/default/sample-webapp.

Spot Fleet request
     * - The resource type is spot-fleet-request and the unique identifier
     * is the Spot Fleet request ID. Example:
     * spot-fleet-request/sfr-73fbd2ce-aa30-494c-8788-1cee4EXAMPLE.

     *

EMR cluster - The resource type is instancegroup and
     * the unique identifier is the cluster ID and instance group ID. Example:
     * instancegroup/j-2EEZNYKUA1NTV/ig-1791Y4E1L8YI0.

     *
AppStream 2.0 fleet - The resource type is fleet and the unique
     * identifier is the fleet name. Example: fleet/sample-fleet.

     *

DynamoDB table - The resource type is table and the
     * unique identifier is the table name. Example: table/my-table.

     *

DynamoDB global secondary index - The resource type is
     * index and the unique identifier is the index name. Example:
     * table/my-table/index/my-table-index.

Aurora DB
     * cluster - The resource type is cluster and the unique identifier is
     * the cluster name. Example: cluster:my-db-cluster.

     *
Amazon SageMaker endpoint variant - The resource type is variant
     * and the unique identifier is the resource ID. Example:
     * endpoint/my-end-point/variant/KMeansClustering.

     *
Custom resources are not supported with a resource type. This parameter must
     * specify the OutputValue from the CloudFormation template stack used
     * to access the resources. The unique identifier is defined by the service
     * provider. More information is available in our GitHub
     * repository.

Amazon Comprehend document classification
     * endpoint - The resource type and unique identifier are specified using the
     * endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:document-classifier-endpoint/EXAMPLE.

     *

Amazon Comprehend entity recognizer endpoint - The resource type
     * and unique identifier are specified using the endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:entity-recognizer-endpoint/EXAMPLE.

     *

Lambda provisioned concurrency - The resource type is
     * function and the unique identifier is the function name with a
     * function version or alias name suffix that is not $LATEST. Example:
     * function:my-function:prod or
     * function:my-function:1.

Amazon Keyspaces table -
     * The resource type is table and the unique identifier is the table
     * name. Example: keyspace/mykeyspace/table/mytable.

     *
Amazon MSK cluster - The resource type and unique identifier are specified
     * using the cluster ARN. Example:
     * arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5.

     *

     */
    inline PutScalingPolicyRequest& WithResourceId(Aws::String&& value) { SetResourceId(std::move(value)); return *this;}

    /**
     *
The identifier of the resource associated with the scaling policy. This
     * string consists of the resource type and unique identifier.

ECS
     * service - The resource type is service and the unique identifier is
     * the cluster name and service name. Example:
     * service/default/sample-webapp.

Spot Fleet request
     * - The resource type is spot-fleet-request and the unique identifier
     * is the Spot Fleet request ID. Example:
     * spot-fleet-request/sfr-73fbd2ce-aa30-494c-8788-1cee4EXAMPLE.

     *

EMR cluster - The resource type is instancegroup and
     * the unique identifier is the cluster ID and instance group ID. Example:
     * instancegroup/j-2EEZNYKUA1NTV/ig-1791Y4E1L8YI0.

     *
AppStream 2.0 fleet - The resource type is fleet and the unique
     * identifier is the fleet name. Example: fleet/sample-fleet.

     *

DynamoDB table - The resource type is table and the
     * unique identifier is the table name. Example: table/my-table.

     *

DynamoDB global secondary index - The resource type is
     * index and the unique identifier is the index name. Example:
     * table/my-table/index/my-table-index.

Aurora DB
     * cluster - The resource type is cluster and the unique identifier is
     * the cluster name. Example: cluster:my-db-cluster.

     *
Amazon SageMaker endpoint variant - The resource type is variant
     * and the unique identifier is the resource ID. Example:
     * endpoint/my-end-point/variant/KMeansClustering.

     *
Custom resources are not supported with a resource type. This parameter must
     * specify the OutputValue from the CloudFormation template stack used
     * to access the resources. The unique identifier is defined by the service
     * provider. More information is available in our GitHub
     * repository.

Amazon Comprehend document classification
     * endpoint - The resource type and unique identifier are specified using the
     * endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:document-classifier-endpoint/EXAMPLE.

     *

Amazon Comprehend entity recognizer endpoint - The resource type
     * and unique identifier are specified using the endpoint ARN. Example:
     * arn:aws:comprehend:us-west-2:123456789012:entity-recognizer-endpoint/EXAMPLE.

     *

Lambda provisioned concurrency - The resource type is
     * function and the unique identifier is the function name with a
     * function version or alias name suffix that is not $LATEST. Example:
     * function:my-function:prod or
     * function:my-function:1.

Amazon Keyspaces table -
     * The resource type is table and the unique identifier is the table
     * name. Example: keyspace/mykeyspace/table/mytable.

     *
Amazon MSK cluster - The resource type and unique identifier are specified
     * using the cluster ARN. Example:
     * arn:aws:kafka:us-east-1:123456789012:cluster/demo-cluster-1/6357e0b2-0e6a-4b86-a0b4-70df934c2e31-5.

     *

     */
    inline PutScalingPolicyRequest& WithResourceId(const char* value) { SetResourceId(value); return *this;}

    /**
     *
The scalable dimension. This string consists of the service namespace,
     * resource type, and scaling property.

     * ecs:service:DesiredCount - The desired task count of an ECS
     * service.

 ec2:spot-fleet-request:TargetCapacity -
     * The target capacity of a Spot Fleet request.

     * elasticmapreduce:instancegroup:InstanceCount - The instance count
     * of an EMR Instance Group.

     * appstream:fleet:DesiredCapacity - The desired capacity of an
     * AppStream 2.0 fleet.

     * dynamodb:table:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB table.

     * dynamodb:table:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB table.

     * dynamodb:index:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB global secondary index.

     * dynamodb:index:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB global secondary index.

     * rds:cluster:ReadReplicaCount - The count of Aurora Replicas in an
     * Aurora DB cluster. Available for Aurora MySQL-compatible edition and Aurora
     * PostgreSQL-compatible edition.

     * sagemaker:variant:DesiredInstanceCount - The number of EC2
     * instances for an Amazon SageMaker model endpoint variant.

     * custom-resource:ResourceType:Property - The scalable dimension for
     * a custom resource provided by your own application or service.

     *
 comprehend:document-classifier-endpoint:DesiredInferenceUnits -
     * The number of inference units for an Amazon Comprehend document classification
     * endpoint.

     * comprehend:entity-recognizer-endpoint:DesiredInferenceUnits - The
     * number of inference units for an Amazon Comprehend entity recognizer
     * endpoint.

 lambda:function:ProvisionedConcurrency
     * - The provisioned concurrency for a Lambda function.

     * cassandra:table:ReadCapacityUnits - The provisioned read capacity
     * for an Amazon Keyspaces table.

     * cassandra:table:WriteCapacityUnits - The provisioned write capacity
     * for an Amazon Keyspaces table.

     * kafka:broker-storage:VolumeSize - The provisioned volume size (in
     * GiB) for brokers in an Amazon MSK cluster.

     */
    inline const ScalableDimension& GetScalableDimension() const{ return m_scalableDimension; }

    /**
     *
The scalable dimension. This string consists of the service namespace,
     * resource type, and scaling property.

     * ecs:service:DesiredCount - The desired task count of an ECS
     * service.

 ec2:spot-fleet-request:TargetCapacity -
     * The target capacity of a Spot Fleet request.

     * elasticmapreduce:instancegroup:InstanceCount - The instance count
     * of an EMR Instance Group.

     * appstream:fleet:DesiredCapacity - The desired capacity of an
     * AppStream 2.0 fleet.

     * dynamodb:table:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB table.

     * dynamodb:table:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB table.

     * dynamodb:index:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB global secondary index.

     * dynamodb:index:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB global secondary index.

     * rds:cluster:ReadReplicaCount - The count of Aurora Replicas in an
     * Aurora DB cluster. Available for Aurora MySQL-compatible edition and Aurora
     * PostgreSQL-compatible edition.

     * sagemaker:variant:DesiredInstanceCount - The number of EC2
     * instances for an Amazon SageMaker model endpoint variant.

     * custom-resource:ResourceType:Property - The scalable dimension for
     * a custom resource provided by your own application or service.

     *
 comprehend:document-classifier-endpoint:DesiredInferenceUnits -
     * The number of inference units for an Amazon Comprehend document classification
     * endpoint.

     * comprehend:entity-recognizer-endpoint:DesiredInferenceUnits - The
     * number of inference units for an Amazon Comprehend entity recognizer
     * endpoint.

 lambda:function:ProvisionedConcurrency
     * - The provisioned concurrency for a Lambda function.

     * cassandra:table:ReadCapacityUnits - The provisioned read capacity
     * for an Amazon Keyspaces table.

     * cassandra:table:WriteCapacityUnits - The provisioned write capacity
     * for an Amazon Keyspaces table.

     * kafka:broker-storage:VolumeSize - The provisioned volume size (in
     * GiB) for brokers in an Amazon MSK cluster.

     */
    inline bool ScalableDimensionHasBeenSet() const { return m_scalableDimensionHasBeenSet; }

    /**
     *
The scalable dimension. This string consists of the service namespace,
     * resource type, and scaling property.

     * ecs:service:DesiredCount - The desired task count of an ECS
     * service.

 ec2:spot-fleet-request:TargetCapacity -
     * The target capacity of a Spot Fleet request.

     * elasticmapreduce:instancegroup:InstanceCount - The instance count
     * of an EMR Instance Group.

     * appstream:fleet:DesiredCapacity - The desired capacity of an
     * AppStream 2.0 fleet.

     * dynamodb:table:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB table.

     * dynamodb:table:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB table.

     * dynamodb:index:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB global secondary index.

     * dynamodb:index:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB global secondary index.

     * rds:cluster:ReadReplicaCount - The count of Aurora Replicas in an
     * Aurora DB cluster. Available for Aurora MySQL-compatible edition and Aurora
     * PostgreSQL-compatible edition.

     * sagemaker:variant:DesiredInstanceCount - The number of EC2
     * instances for an Amazon SageMaker model endpoint variant.

     * custom-resource:ResourceType:Property - The scalable dimension for
     * a custom resource provided by your own application or service.

     *
 comprehend:document-classifier-endpoint:DesiredInferenceUnits -
     * The number of inference units for an Amazon Comprehend document classification
     * endpoint.

     * comprehend:entity-recognizer-endpoint:DesiredInferenceUnits - The
     * number of inference units for an Amazon Comprehend entity recognizer
     * endpoint.

 lambda:function:ProvisionedConcurrency
     * - The provisioned concurrency for a Lambda function.

     * cassandra:table:ReadCapacityUnits - The provisioned read capacity
     * for an Amazon Keyspaces table.

     * cassandra:table:WriteCapacityUnits - The provisioned write capacity
     * for an Amazon Keyspaces table.

     * kafka:broker-storage:VolumeSize - The provisioned volume size (in
     * GiB) for brokers in an Amazon MSK cluster.

     */
    inline void SetScalableDimension(const ScalableDimension& value) { m_scalableDimensionHasBeenSet = true; m_scalableDimension = value; }

    /**
     *
The scalable dimension. This string consists of the service namespace,
     * resource type, and scaling property.

     * ecs:service:DesiredCount - The desired task count of an ECS
     * service.

 ec2:spot-fleet-request:TargetCapacity -
     * The target capacity of a Spot Fleet request.

     * elasticmapreduce:instancegroup:InstanceCount - The instance count
     * of an EMR Instance Group.

     * appstream:fleet:DesiredCapacity - The desired capacity of an
     * AppStream 2.0 fleet.

     * dynamodb:table:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB table.

     * dynamodb:table:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB table.

     * dynamodb:index:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB global secondary index.

     * dynamodb:index:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB global secondary index.

     * rds:cluster:ReadReplicaCount - The count of Aurora Replicas in an
     * Aurora DB cluster. Available for Aurora MySQL-compatible edition and Aurora
     * PostgreSQL-compatible edition.

     * sagemaker:variant:DesiredInstanceCount - The number of EC2
     * instances for an Amazon SageMaker model endpoint variant.

     * custom-resource:ResourceType:Property - The scalable dimension for
     * a custom resource provided by your own application or service.

     *
 comprehend:document-classifier-endpoint:DesiredInferenceUnits -
     * The number of inference units for an Amazon Comprehend document classification
     * endpoint.

     * comprehend:entity-recognizer-endpoint:DesiredInferenceUnits - The
     * number of inference units for an Amazon Comprehend entity recognizer
     * endpoint.

 lambda:function:ProvisionedConcurrency
     * - The provisioned concurrency for a Lambda function.

     * cassandra:table:ReadCapacityUnits - The provisioned read capacity
     * for an Amazon Keyspaces table.

     * cassandra:table:WriteCapacityUnits - The provisioned write capacity
     * for an Amazon Keyspaces table.

     * kafka:broker-storage:VolumeSize - The provisioned volume size (in
     * GiB) for brokers in an Amazon MSK cluster.

     */
    inline void SetScalableDimension(ScalableDimension&& value) { m_scalableDimensionHasBeenSet = true; m_scalableDimension = std::move(value); }

    /**
     *
The scalable dimension. This string consists of the service namespace,
     * resource type, and scaling property.

     * ecs:service:DesiredCount - The desired task count of an ECS
     * service.

 ec2:spot-fleet-request:TargetCapacity -
     * The target capacity of a Spot Fleet request.

     * elasticmapreduce:instancegroup:InstanceCount - The instance count
     * of an EMR Instance Group.

     * appstream:fleet:DesiredCapacity - The desired capacity of an
     * AppStream 2.0 fleet.

     * dynamodb:table:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB table.

     * dynamodb:table:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB table.

     * dynamodb:index:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB global secondary index.

     * dynamodb:index:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB global secondary index.

     * rds:cluster:ReadReplicaCount - The count of Aurora Replicas in an
     * Aurora DB cluster. Available for Aurora MySQL-compatible edition and Aurora
     * PostgreSQL-compatible edition.

     * sagemaker:variant:DesiredInstanceCount - The number of EC2
     * instances for an Amazon SageMaker model endpoint variant.

     * custom-resource:ResourceType:Property - The scalable dimension for
     * a custom resource provided by your own application or service.

     *
 comprehend:document-classifier-endpoint:DesiredInferenceUnits -
     * The number of inference units for an Amazon Comprehend document classification
     * endpoint.

     * comprehend:entity-recognizer-endpoint:DesiredInferenceUnits - The
     * number of inference units for an Amazon Comprehend entity recognizer
     * endpoint.

 lambda:function:ProvisionedConcurrency
     * - The provisioned concurrency for a Lambda function.

     * cassandra:table:ReadCapacityUnits - The provisioned read capacity
     * for an Amazon Keyspaces table.

     * cassandra:table:WriteCapacityUnits - The provisioned write capacity
     * for an Amazon Keyspaces table.

     * kafka:broker-storage:VolumeSize - The provisioned volume size (in
     * GiB) for brokers in an Amazon MSK cluster.

     */
    inline PutScalingPolicyRequest& WithScalableDimension(const ScalableDimension& value) { SetScalableDimension(value); return *this;}

    /**
     *
The scalable dimension. This string consists of the service namespace,
     * resource type, and scaling property.

     * ecs:service:DesiredCount - The desired task count of an ECS
     * service.

 ec2:spot-fleet-request:TargetCapacity -
     * The target capacity of a Spot Fleet request.

     * elasticmapreduce:instancegroup:InstanceCount - The instance count
     * of an EMR Instance Group.

     * appstream:fleet:DesiredCapacity - The desired capacity of an
     * AppStream 2.0 fleet.

     * dynamodb:table:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB table.

     * dynamodb:table:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB table.

     * dynamodb:index:ReadCapacityUnits - The provisioned read capacity
     * for a DynamoDB global secondary index.

     * dynamodb:index:WriteCapacityUnits - The provisioned write capacity
     * for a DynamoDB global secondary index.

     * rds:cluster:ReadReplicaCount - The count of Aurora Replicas in an
     * Aurora DB cluster. Available for Aurora MySQL-compatible edition and Aurora
     * PostgreSQL-compatible edition.

     * sagemaker:variant:DesiredInstanceCount - The number of EC2
     * instances for an Amazon SageMaker model endpoint variant.

     * custom-resource:ResourceType:Property - The scalable dimension for
     * a custom resource provided by your own application or service.

     *
 comprehend:document-classifier-endpoint:DesiredInferenceUnits -
     * The number of inference units for an Amazon Comprehend document classification
     * endpoint.

     * comprehend:entity-recognizer-endpoint:DesiredInferenceUnits - The
     * number of inference units for an Amazon Comprehend entity recognizer
     * endpoint.

 lambda:function:ProvisionedConcurrency
     * - The provisioned concurrency for a Lambda function.

     * cassandra:table:ReadCapacityUnits - The provisioned read capacity
     * for an Amazon Keyspaces table.

     * cassandra:table:WriteCapacityUnits - The provisioned write capacity
     * for an Amazon Keyspaces table.

     * kafka:broker-storage:VolumeSize - The provisioned volume size (in
     * GiB) for brokers in an Amazon MSK cluster.

     */
    inline PutScalingPolicyRequest& WithScalableDimension(ScalableDimension&& value) { SetScalableDimension(std::move(value)); return *this;}

    /**
     *
The policy type. This parameter is required if you are creating a scaling
     * policy.

The following policy types are supported:

     * TargetTrackingScaling—Not supported for Amazon EMR

     * StepScaling—Not supported for DynamoDB, Amazon Comprehend, Lambda,
     * Amazon Keyspaces (for Apache Cassandra), or Amazon MSK.

For more
     * information, see Target
     * Tracking Scaling Policies and Step
     * Scaling Policies in the Application Auto Scaling User Guide.

     */
    inline const PolicyType& GetPolicyType() const{ return m_policyType; }

    /**
     *
The policy type. This parameter is required if you are creating a scaling
     * policy.

The following policy types are supported:

     * TargetTrackingScaling—Not supported for Amazon EMR

     * StepScaling—Not supported for DynamoDB, Amazon Comprehend, Lambda,
     * Amazon Keyspaces (for Apache Cassandra), or Amazon MSK.

For more
     * information, see Target
     * Tracking Scaling Policies and Step
     * Scaling Policies in the Application Auto Scaling User Guide.

     */
    inline bool PolicyTypeHasBeenSet() const { return m_policyTypeHasBeenSet; }

    /**
     *
The policy type. This parameter is required if you are creating a scaling
     * policy.

The following policy types are supported:

     * TargetTrackingScaling—Not supported for Amazon EMR

     * StepScaling—Not supported for DynamoDB, Amazon Comprehend, Lambda,
     * Amazon Keyspaces (for Apache Cassandra), or Amazon MSK.

For more
     * information, see Target
     * Tracking Scaling Policies and Step
     * Scaling Policies in the Application Auto Scaling User Guide.

     */
    inline void SetPolicyType(const PolicyType& value) { m_policyTypeHasBeenSet = true; m_policyType = value; }

    /**
     *
The policy type. This parameter is required if you are creating a scaling
     * policy.

The following policy types are supported:

     * TargetTrackingScaling—Not supported for Amazon EMR

     * StepScaling—Not supported for DynamoDB, Amazon Comprehend, Lambda,
     * Amazon Keyspaces (for Apache Cassandra), or Amazon MSK.

For more
     * information, see Target
     * Tracking Scaling Policies and Step
     * Scaling Policies in the Application Auto Scaling User Guide.

     */
    inline void SetPolicyType(PolicyType&& value) { m_policyTypeHasBeenSet = true; m_policyType = std::move(value); }

    /**
     *
The policy type. This parameter is required if you are creating a scaling
     * policy.

The following policy types are supported:

     * TargetTrackingScaling—Not supported for Amazon EMR

     * StepScaling—Not supported for DynamoDB, Amazon Comprehend, Lambda,
     * Amazon Keyspaces (for Apache Cassandra), or Amazon MSK.

For more
     * information, see Target
     * Tracking Scaling Policies and Step
     * Scaling Policies in the Application Auto Scaling User Guide.

     */
    inline PutScalingPolicyRequest& WithPolicyType(const PolicyType& value) { SetPolicyType(value); return *this;}

    /**
     *
The policy type. This parameter is required if you are creating a scaling
     * policy.

The following policy types are supported:

     * TargetTrackingScaling—Not supported for Amazon EMR

     * StepScaling—Not supported for DynamoDB, Amazon Comprehend, Lambda,
     * Amazon Keyspaces (for Apache Cassandra), or Amazon MSK.

For more
     * information, see Target
     * Tracking Scaling Policies and Step
     * Scaling Policies in the Application Auto Scaling User Guide.

     */
    inline PutScalingPolicyRequest& WithPolicyType(PolicyType&& value) { SetPolicyType(std::move(value)); return *this;}

    /**
     *
A step scaling policy.

This parameter is required if you are creating
     * a policy and the policy type is StepScaling.

     */
    inline const StepScalingPolicyConfiguration& GetStepScalingPolicyConfiguration() const{ return m_stepScalingPolicyConfiguration; }

    /**
     *
A step scaling policy.

This parameter is required if you are creating
     * a policy and the policy type is StepScaling.

     */
    inline bool StepScalingPolicyConfigurationHasBeenSet() const { return m_stepScalingPolicyConfigurationHasBeenSet; }

    /**
     *
A step scaling policy.

This parameter is required if you are creating
     * a policy and the policy type is StepScaling.

     */
    inline void SetStepScalingPolicyConfiguration(const StepScalingPolicyConfiguration& value) { m_stepScalingPolicyConfigurationHasBeenSet = true; m_stepScalingPolicyConfiguration = value; }

    /**
     *
A step scaling policy.

This parameter is required if you are creating
     * a policy and the policy type is StepScaling.

     */
    inline void SetStepScalingPolicyConfiguration(StepScalingPolicyConfiguration&& value) { m_stepScalingPolicyConfigurationHasBeenSet = true; m_stepScalingPolicyConfiguration = std::move(value); }

    /**
     *
A step scaling policy.

This parameter is required if you are creating
     * a policy and the policy type is StepScaling.

     */
    inline PutScalingPolicyRequest& WithStepScalingPolicyConfiguration(const StepScalingPolicyConfiguration& value) { SetStepScalingPolicyConfiguration(value); return *this;}

    /**
     *
A step scaling policy.

This parameter is required if you are creating
     * a policy and the policy type is StepScaling.

     */
    inline PutScalingPolicyRequest& WithStepScalingPolicyConfiguration(StepScalingPolicyConfiguration&& value) { SetStepScalingPolicyConfiguration(std::move(value)); return *this;}

    /**
     *
A target tracking scaling policy. Includes support for predefined or
     * customized metrics.

This parameter is required if you are creating a
     * policy and the policy type is TargetTrackingScaling.

     */
    inline const TargetTrackingScalingPolicyConfiguration& GetTargetTrackingScalingPolicyConfiguration() const{ return m_targetTrackingScalingPolicyConfiguration; }

    /**
     *
A target tracking scaling policy. Includes support for predefined or
     * customized metrics.

This parameter is required if you are creating a
     * policy and the policy type is TargetTrackingScaling.

     */
    inline bool TargetTrackingScalingPolicyConfigurationHasBeenSet() const { return m_targetTrackingScalingPolicyConfigurationHasBeenSet; }

    /**
     *
A target tracking scaling policy. Includes support for predefined or
     * customized metrics.

This parameter is required if you are creating a
     * policy and the policy type is TargetTrackingScaling.

     */
    inline void SetTargetTrackingScalingPolicyConfiguration(const TargetTrackingScalingPolicyConfiguration& value) { m_targetTrackingScalingPolicyConfigurationHasBeenSet = true; m_targetTrackingScalingPolicyConfiguration = value; }

    /**
     *
A target tracking scaling policy. Includes support for predefined or
     * customized metrics.

This parameter is required if you are creating a
     * policy and the policy type is TargetTrackingScaling.

     */
    inline void SetTargetTrackingScalingPolicyConfiguration(TargetTrackingScalingPolicyConfiguration&& value) { m_targetTrackingScalingPolicyConfigurationHasBeenSet = true; m_targetTrackingScalingPolicyConfiguration = std::move(value); }

    /**
     *
A target tracking scaling policy. Includes support for predefined or
     * customized metrics.

This parameter is required if you are creating a
     * policy and the policy type is TargetTrackingScaling.

     */
    inline PutScalingPolicyRequest& WithTargetTrackingScalingPolicyConfiguration(const TargetTrackingScalingPolicyConfiguration& value) { SetTargetTrackingScalingPolicyConfiguration(value); return *this;}

    /**
     *
A target tracking scaling policy. Includes support for predefined or
     * customized metrics.

This parameter is required if you are creating a
     * policy and the policy type is TargetTrackingScaling.

     */
    inline PutScalingPolicyRequest& WithTargetTrackingScalingPolicyConfiguration(TargetTrackingScalingPolicyConfiguration&& value) { SetTargetTrackingScalingPolicyConfiguration(std::move(value)); return *this;}

  private:

    Aws::String m_policyName;
    bool m_policyNameHasBeenSet;

    ServiceNamespace m_serviceNamespace;
    bool m_serviceNamespaceHasBeenSet;

    Aws::String m_resourceId;
    bool m_resourceIdHasBeenSet;

    ScalableDimension m_scalableDimension;
    bool m_scalableDimensionHasBeenSet;

    PolicyType m_policyType;
    bool m_policyTypeHasBeenSet;

    StepScalingPolicyConfiguration m_stepScalingPolicyConfiguration;
    bool m_stepScalingPolicyConfigurationHasBeenSet;

    TargetTrackingScalingPolicyConfiguration m_targetTrackingScalingPolicyConfiguration;
    bool m_targetTrackingScalingPolicyConfigurationHasBeenSet;
  };

} // namespace Model
} // namespace ApplicationAutoScaling
} // namespace Aws


text:
<?php

namespace Integrated\Common\Solr\Tests\Task\Tasks\Doctrine;

use Integrated\Common\Solr\Task\Tasks\Doctrine\MongoDBReferenceQueueTask;

/**
 * @author Jan Sanne Mulder <jansanne@e-active.nl>
 */
class MongoDBReferenceQueueTaskTest extends \Integrated\Common\Solr\Tests\Task\Tasks\ReferenceQueueTaskTest
{
    protected function getInstance($id)
    {
        return new MongoDBReferenceQueueTask($id);
    }
}


text:
function model = fgplvmAddDynamics(model, type, varargin)

% FGPLVMADDDYNAMICS Add a dynamics kernel to the model.
%
%	Description:
%
%	FGPLVMADDDYNAMICS(MODEL, TYPE, ...) adds a dynamics model to the
%	FGPLVM.
%	 Arguments:
%	  MODEL - the model to add dynamics to.
%	  TYPE - the type of dynamics model to add in.
%	  ... - additional arguments to be passed on creation of the
%	   dynamics model.
%
%
%
%
%	See also
%	MODELCREATE

%	Copyright (c) 2005, 2006, 2007 Neil D. Lawrence

%	With modifications by Carl Henrik Ek 2008

type = [type 'Dynamics'];
model.dynamics = modelCreate(type, model.q, model.q, model.X, varargin{:});
params = fgplvmExtractParam(model);
model.dynamics.numParams = length(modelExtractParam(model.dynamics));
model.numParams = model.numParams + model.dynamics.numParams;
model = fgplvmExpandParam(model, params);


text:
package jsonem

import (
	"io"

	"v2ray.com/core"
	"v2ray.com/core/common"
	"v2ray.com/core/common/cmdarg"
	"v2ray.com/core/infra/conf"
	"v2ray.com/core/infra/conf/serial"
	"v2ray.com/core/main/confloader"
)

func init() {
	common.Must(core.RegisterConfigLoader(&core.ConfigFormat{
		Name:      "JSON",
		Extension: []string{"json"},
		Loader: func(input interface{}) (*core.Config, error) {
			switch v := input.(type) {
			case cmdarg.Arg:
				cf := &conf.Config{}
				for _, arg := range v {
					newError("Reading config: ", arg).AtInfo().WriteToLog()
					r, err := confloader.LoadConfig(arg)
					common.Must(err)
					c, err := serial.DecodeJSONConfig(r)
					common.Must(err)
					cf.Override(c, arg)
				}
				return cf.Build()
			case io.Reader:
				return serial.LoadJSONConfig(v)
			default:
				return nil, newError("unknow type")
			}
		},
	}))
}


text:
<!DOCTYPE html>

    <meta charset="UTF-8">
    <title>Formación Angular</title>
    <link rel="stylesheet" href="demoApp.css">

  Selecciona un País:
  ESPAÑA |
  FRANCIA |
  REINO UNIDO |
  ITALIA |
  ALEMANIA|
  OTRA FORMA ACCEDER ESPAÑA|
  NO EXISTE